app.Ticket.Run - Code Metrics - cronnoss/tk-api - Measure and Improve Code Quality continuously with Scrutinizer

app.Ticket.Run C
last analyzed 2024-09-17 15:27 UTC

↳ Parent: internal/app/ticket.go

Complexity

Conditions

Size

Total Lines	35
Code Lines	22

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	10
eloc	22
dl	0
loc	35
c	0
b	0
f	0
rs	5.9999
nop	1

How to fix Complexity

package app

import (
	"context"
	"errors"
	"fmt"
	"net/http"
	"os/signal"
	"syscall"
	"time"

	"github.com/cronnoss/tk-api/internal/logger"
	"github.com/cronnoss/tk-api/internal/server"
	"github.com/cronnoss/tk-api/internal/storage"
	"github.com/cronnoss/tk-api/internal/storage/models"
	"golang.org/x/sync/errgroup"
)

type TicketConf struct {
	Logger  logger.Conf  `toml:"logger"`
	Storage storage.Conf `toml:"storage"`
	HTTP    struct {
		Host string `toml:"host"`
		Port string `toml:"port"`
	} `toml:"http-server"`
}

type Ticket struct {
	conf    TicketConf
	log     server.Logger
	storage Storage
}

type Storage interface {
	Connect(ctx context.Context) error
	Close(ctx context.Context) error
	GetShows(ctx context.Context) ([]models.Show, error)
	CreateShows(ctx context.Context, shows []models.Show) ([]models.Show, error)
	CreateShow(ctx context.Context, shows models.Show) (models.Show, error)
	GetEvents(ctx context.Context) ([]models.Event, error)
	CreateEvents(ctx context.Context, events []models.Event) ([]models.Event, error)
	CreateEvent(ctx context.Context, event models.Event) (models.Event, error)
	GetPlaces(ctx context.Context) ([]models.Place, error)
	CreatePlaces(ctx context.Context, places []models.Place) ([]models.Place, error)
	CreatePlace(ctx context.Context, place models.Place) (models.Place, error)
}

type Server interface {
	Start(context.Context) error
	Stop(context.Context) error
}

func (t *Ticket) GetShows(ctx context.Context) ([]models.Show, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.GetShows(ctx)
}

func (t *Ticket) CreateShows(ctx context.Context, shows []models.Show) ([]models.Show, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.CreateShows(ctx, shows)
}

func (t *Ticket) CreateShow(ctx context.Context, show models.Show) (models.Show, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.CreateShow(ctx, show)
}

func (t *Ticket) GetEvents(ctx context.Context) ([]models.Event, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.GetEvents(ctx)
}

func (t *Ticket) CreateEvents(ctx context.Context, events []models.Event) ([]models.Event, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.CreateEvents(ctx, events)
}

func (t *Ticket) CreateEvent(ctx context.Context, event models.Event) (models.Event, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.CreateEvent(ctx, event)
}

func (t *Ticket) GetPlaces(ctx context.Context) ([]models.Place, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.GetPlaces(ctx)
}

func (t *Ticket) CreatePlaces(ctx context.Context, places []models.Place) ([]models.Place, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.CreatePlaces(ctx, places)
}

func (t *Ticket) CreatePlace(ctx context.Context, place models.Place) (models.Place, error) {
	ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()
	return t.storage.CreatePlace(ctx, place)
}

func NewTicket(log server.Logger, conf TicketConf, storage Storage) (*Ticket, error) {
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	if err := storage.Connect(ctx); err != nil {
		server.Exitfail(fmt.Sprintf("Can't connect to storage:%v", err))
	}

	return &Ticket{log: log, conf: conf, storage: storage}, nil
}

func (t Ticket) Run(httpsrv Server) {
	ctx, cancel := signal.NotifyContext(context.Background(),
		syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
	defer cancel()

	g, ctxEG := errgroup.WithContext(ctx)

	func1 := func() error {
		return httpsrv.Start(ctxEG)
	}

	go func() {
		<-ctx.Done()

		ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
		defer cancel()

		if err := httpsrv.Stop(ctx); err != nil {
			if !errors.Is(err, http.ErrServerClosed) &&
				!errors.Is(err, context.Canceled) {
				t.log.Errorf("failed to stop HTTP-server:%v\n", err)
			}
		}

		if err := t.storage.Close(ctx); err != nil {
			t.log.Errorf("failed to close db:%v\n", err)
		}
	}()

	g.Go(func1)

	if err := g.Wait(); err != nil {
		if !errors.Is(err, http.ErrServerClosed) &&
			!errors.Is(err, context.Canceled) {
			t.log.Errorf("%v\n", err)
		}
	}
}


1			package app
2
3			import (
4			"context"
5			"errors"
6			"fmt"
7			"net/http"
8			"os/signal"
9			"syscall"
10			"time"
11
12			"github.com/cronnoss/tk-api/internal/logger"
13			"github.com/cronnoss/tk-api/internal/server"
14			"github.com/cronnoss/tk-api/internal/storage"
15			"github.com/cronnoss/tk-api/internal/storage/models"
16			"golang.org/x/sync/errgroup"
17			)
18
19			type TicketConf struct {
20			Logger logger.Conf `toml:"logger"`
21			Storage storage.Conf `toml:"storage"`
22			HTTP struct {
23			Host string `toml:"host"`
24			Port string `toml:"port"`
25			} `toml:"http-server"`
26			}
27
28			type Ticket struct {
29			conf TicketConf
30			log server.Logger
31			storage Storage
32			}
33
34			type Storage interface {
35			Connect(ctx context.Context) error
36			Close(ctx context.Context) error
37			GetShows(ctx context.Context) ([]models.Show, error)
38			CreateShows(ctx context.Context, shows []models.Show) ([]models.Show, error)
39			CreateShow(ctx context.Context, shows models.Show) (models.Show, error)
40			GetEvents(ctx context.Context) ([]models.Event, error)
41			CreateEvents(ctx context.Context, events []models.Event) ([]models.Event, error)
42			CreateEvent(ctx context.Context, event models.Event) (models.Event, error)
43			GetPlaces(ctx context.Context) ([]models.Place, error)
44			CreatePlaces(ctx context.Context, places []models.Place) ([]models.Place, error)
45			CreatePlace(ctx context.Context, place models.Place) (models.Place, error)
46			}
47
48			type Server interface {
49			Start(context.Context) error
50			Stop(context.Context) error
51			}
52
53			func (t *Ticket) GetShows(ctx context.Context) ([]models.Show, error) {
54			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
55			defer cancel()
56			return t.storage.GetShows(ctx)
57			}
58
59			func (t *Ticket) CreateShows(ctx context.Context, shows []models.Show) ([]models.Show, error) {
60			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
61			defer cancel()
62			return t.storage.CreateShows(ctx, shows)
63			}
64
65			func (t *Ticket) CreateShow(ctx context.Context, show models.Show) (models.Show, error) {
66			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
67			defer cancel()
68			return t.storage.CreateShow(ctx, show)
69			}
70
71			func (t *Ticket) GetEvents(ctx context.Context) ([]models.Event, error) {
72			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
73			defer cancel()
74			return t.storage.GetEvents(ctx)
75			}
76
77			func (t *Ticket) CreateEvents(ctx context.Context, events []models.Event) ([]models.Event, error) {
78			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
79			defer cancel()
80			return t.storage.CreateEvents(ctx, events)
81			}
82
83			func (t *Ticket) CreateEvent(ctx context.Context, event models.Event) (models.Event, error) {
84			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
85			defer cancel()
86			return t.storage.CreateEvent(ctx, event)
87			}
88
89			func (t *Ticket) GetPlaces(ctx context.Context) ([]models.Place, error) {
90			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
91			defer cancel()
92			return t.storage.GetPlaces(ctx)
93			}
94
95			func (t *Ticket) CreatePlaces(ctx context.Context, places []models.Place) ([]models.Place, error) {
96			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
97			defer cancel()
98			return t.storage.CreatePlaces(ctx, places)
99			}
100
101			func (t *Ticket) CreatePlace(ctx context.Context, place models.Place) (models.Place, error) {
102			ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
103			defer cancel()
104			return t.storage.CreatePlace(ctx, place)
105			}
106
107			func NewTicket(log server.Logger, conf TicketConf, storage Storage) (*Ticket, error) {
108			ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
109			defer cancel()
110
111			if err := storage.Connect(ctx); err != nil {
112			server.Exitfail(fmt.Sprintf("Can't connect to storage:%v", err))
113			}
114
115			return &Ticket{log: log, conf: conf, storage: storage}, nil
116			}
117
118			func (t Ticket) Run(httpsrv Server) {
119			ctx, cancel := signal.NotifyContext(context.Background(),
120			syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
121			defer cancel()
122
123			g, ctxEG := errgroup.WithContext(ctx)
124
125			func1 := func() error {
126			return httpsrv.Start(ctxEG)
127			}
128
129			go func() {
130			<-ctx.Done()
131
132			ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
133			defer cancel()
134
135			if err := httpsrv.Stop(ctx); err != nil {
136			if !errors.Is(err, http.ErrServerClosed) &&
137			!errors.Is(err, context.Canceled) {
138			t.log.Errorf("failed to stop HTTP-server:%v\n", err)
139			}
140			}
141
142			if err := t.storage.Close(ctx); err != nil {
143			t.log.Errorf("failed to close db:%v\n", err)
144			}
145			}()
146
147			g.Go(func1)
148
149			if err := g.Wait(); err != nil {
150			if !errors.Is(err, http.ErrServerClosed) &&
151			!errors.Is(err, context.Canceled) {
152			t.log.Errorf("%v\n", err)
153			}
154			}
155			}
156

cronnoss / tk-api

app.Ticket.Run C last analyzed 2024-09-17 15:27 UTC

Complexity

Size

Duplication

Importance

How to fix Complexity

Complexity

Duplication Side-by-Side

Filter issues like

app.Ticket.Run C
last analyzed 2024-09-17 15:27 UTC