update to v0.8.0

app/mydispatcher/default.go

@@ -95,7 +95,7 @@ type DefaultDispatcher struct {
 	router      routing.Router
 	policy      policy.Manager
 	stats       stats.Manager
-	hosts  dns.HostsLookup
+	hosts       dns.HostsLookup
 	Limiter     *limiter.Limiter
 	RuleManager *rule.RuleManager
 }
@@ -139,7 +139,7 @@ func (*DefaultDispatcher) Start() error {
 // Close implements common.Closable.
 func (*DefaultDispatcher) Close() error { return nil }
 
-func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *transport.Link) {
+func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *transport.Link, error) {
 	opt := pipe.OptionsFromContext(ctx)
 	uplinkReader, uplinkWriter := pipe.New(opt...)
 	downlinkReader, downlinkWriter := pipe.New(opt...)
@@ -169,6 +169,7 @@ func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *tran
 			common.Close(inboundLink.Writer)
 			common.Interrupt(outboundLink.Reader)
 			common.Interrupt(inboundLink.Reader)
+			return nil, nil, newError("Devices reach the limit: ", user.Email)
 		}
 		if ok {
 			inboundLink.Writer = d.Limiter.RateWriter(inboundLink.Writer, bucket)
@@ -195,7 +196,7 @@ func (d *DefaultDispatcher) getLink(ctx context.Context) (*transport.Link, *tran
 		}
 	}
 
-	return inboundLink, outboundLink
+	return inboundLink, outboundLink, nil
 }
 
 func shouldOverride(ctx context.Context, result SniffResult, request session.SniffingRequest, destination net.Destination) bool {
@@ -242,7 +243,10 @@ func (d *DefaultDispatcher) Dispatch(ctx context.Context, destination net.Destin
 	}
 	ctx = session.ContextWithOutbound(ctx, ob)
 
-	inbound, outbound := d.getLink(ctx)
+	inbound, outbound, err := d.getLink(ctx)
+	if err != nil {
+		return nil, err
+	}
 	content := session.ContentFromContext(ctx)
 	if content == nil {
 		content = new(session.Content)

main/main.go

@@ -23,7 +23,7 @@ var (
 )
 
 var (
-	version  = "0.7.6"
+	version  = "0.8.0"
 	codename = "XrayR"
 	intro    = "A Xray backend that supports many panels"
 )