package stratum import ( "log" "regexp" "strings" "../util" ) var noncePattern *regexp.Regexp func init() { noncePattern, _ = regexp.Compile("^[0-9a-f]{8}$") } func (s *StratumServer) handleLoginRPC(cs *Session, e *Endpoint, params *LoginParams) (reply *JobReply, errorReply *ErrorReply) { if !s.config.BypassAddressValidation && !util.ValidateAddress(params.Login, s.config.Address) { errorReply = &ErrorReply{Code: -1, Message: "Invalid address used for login", Close: true} return } miner := NewMiner(params.Login, params.Pass, e.config.Difficulty, cs.ip) miner.Session = cs miner.Endpoint = e s.registerMiner(miner) miner.heartbeat() log.Printf("Miner connected %s@%s", params.Login, miner.IP) reply = &JobReply{} reply.Id = miner.Id reply.Job = miner.getJob(s) reply.Status = "OK" return } func (s *StratumServer) handleGetJobRPC(cs *Session, e *Endpoint, params *GetJobParams) (reply *JobReplyData, errorReply *ErrorReply) { miner, ok := s.miners.Get(params.Id) if !ok { errorReply = &ErrorReply{Code: -1, Message: "Unauthenticated", Close: true} return } miner.heartbeat() reply = miner.getJob(s) return } func (s *StratumServer) handleSubmitRPC(cs *Session, e *Endpoint, params *SubmitParams) (reply *SubmitReply, errorReply *ErrorReply) { miner, ok := s.miners.Get(params.Id) if !ok { errorReply = &ErrorReply{Code: -1, Message: "Unauthenticated", Close: true} return } miner.heartbeat() job := miner.findJob(params.JobId) if job == nil { errorReply = &ErrorReply{Code: -1, Message: "Invalid job id", Close: true} return } if !noncePattern.MatchString(params.Nonce) { errorReply = &ErrorReply{Code: -1, Message: "Malformed nonce", Close: true} return } nonce := strings.ToLower(params.Nonce) exist := job.submit(nonce) if exist { errorReply = &ErrorReply{Code: -1, Message: "Duplicate share", Close: true} return } t := s.currentBlockTemplate() if job.Height != t.Height { log.Printf("Block expired for height %v %s@%s", job.Height, miner.Login, miner.IP) errorReply = &ErrorReply{Code: -1, Message: "Block expired", Close: false} return } validShare := miner.processShare(s, e, job, t, nonce, params.Result) if !validShare { errorReply = &ErrorReply{Code: -1, Message: "Low difficulty share", Close: !ok} return } reply = &SubmitReply{Status: "OK"} return } func (s *StratumServer) handleUnknownRPC(cs *Session, req *JSONRpcReq) *ErrorReply { log.Printf("Unknown RPC method: %v", req) return &ErrorReply{Code: -1, Message: "Invalid method", Close: true} } func (s *StratumServer) broadcastNewJobs() { log.Printf("Broadcasting new jobs to %v miners", s.miners.Count()) bcast := make(chan int, 1024*16) n := 0 for m := range s.miners.IterBuffered() { n++ bcast <- n go func(miner *Miner) { reply := miner.getJob(s) err := miner.Session.pushMessage("job", &reply) <-bcast if err != nil { log.Printf("Job transmit error to %v@%v: %v", miner.Login, miner.IP, err) s.removeMiner(miner.Id) } else { s.setDeadline(miner.Session.conn) } }(m.Val) } } func (s *StratumServer) refreshBlockTemplate(bcast bool) { newBlock := s.fetchBlockTemplate() if newBlock && bcast { s.broadcastNewJobs() } }