generated from VLADIMIR/template
fix
This commit is contained in:
@@ -74,16 +74,22 @@ func TestChangeUserPasswordTransports(t *testing.T) {
|
||||
repo := &passwordRepo{role: "admin"}
|
||||
svc := users_service.NewUsersService(repo, nil, nil, nil, nil, "")
|
||||
listener := bufconn.Listen(1024 * 1024)
|
||||
defer listener.Close()
|
||||
defer func() { _ = listener.Close() }()
|
||||
gs := grpc.NewServer(grpc.UnaryInterceptor(processor_jwt.NewAuthorizationInterceptor(nil, jwt)))
|
||||
proto.RegisterEveningDetectiveServerServer(gs, &server{usersService: svc})
|
||||
go gs.Serve(listener)
|
||||
defer gs.Stop()
|
||||
serveErr := make(chan error, 1)
|
||||
go func() { serveErr <- gs.Serve(listener) }()
|
||||
defer func() {
|
||||
gs.Stop()
|
||||
if err := <-serveErr; err != nil && !errors.Is(err, grpc.ErrServerStopped) {
|
||||
t.Errorf("gRPC server: %v", err)
|
||||
}
|
||||
}()
|
||||
conn, err := grpc.NewClient("passthrough:///test", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(context.Context, string) (net.Conn, error) { return listener.Dial() }))
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer conn.Close()
|
||||
defer func() { _ = conn.Close() }()
|
||||
mux := runtime.NewServeMux()
|
||||
if err := proto.RegisterEveningDetectiveServerHandler(ctx, mux, conn); err != nil {
|
||||
t.Fatal(err)
|
||||
|
||||
@@ -56,7 +56,7 @@ func startSMTPTestServer(t *testing.T, hang bool, cert tls.Certificate) (addr st
|
||||
// handleSMTPConn обслуживает один SMTP-диалог, достаточный для net/smtp:
|
||||
// EHLO, AUTH PLAIN, MAIL, RCPT, DATA, QUIT.
|
||||
func handleSMTPConn(conn net.Conn, messages chan<- []byte) {
|
||||
defer conn.Close()
|
||||
defer func() { _ = conn.Close() }()
|
||||
|
||||
r := bufio.NewReader(conn)
|
||||
write := func(s string) { _, _ = conn.Write([]byte(s)) }
|
||||
|
||||
@@ -929,7 +929,9 @@ func TestScenarioBackgroundLifecycle(t *testing.T) {
|
||||
if strings.Contains(repo.byID[id].Scenario, testDomain) {
|
||||
t.Fatal("stored absolute URL")
|
||||
}
|
||||
storage.Put(ctx, &file_storage.File{Name: "room.png", Data: []byte("image")})
|
||||
if err := storage.Put(ctx, &file_storage.File{Name: "room.png", Data: []byte("image")}); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
data, _, err := service.DownloadArchive(ctx, id, 7, false)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
|
||||
Reference in New Issue
Block a user