resurrect service stuff

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

service.go

@@ -0,0 +1,173 @@
+package micro
+
+import (
+	"os"
+	"os/signal"
+	rtime "runtime"
+	"sync"
+
+	cmd "github.com/unistack-org/micro-config-cmd"
+	"github.com/unistack-org/micro/v3/client"
+	"github.com/unistack-org/micro/v3/logger"
+	"github.com/unistack-org/micro/v3/server"
+	"github.com/unistack-org/micro/v3/store"
+	signalutil "github.com/unistack-org/micro/v3/util/signal"
+)
+
+type service struct {
+	opts Options
+
+	once sync.Once
+}
+
+func newService(opts ...Option) Service {
+	service := &service{}
+	options := newOptions(opts...)
+
+	// set opts
+	service.opts = options
+
+	return service
+}
+
+func (s *service) Name() string {
+	return s.opts.Server.Options().Name
+}
+
+// Init initialises options. Additionally it calls cmd.Init
+// which parses command line flags. cmd.Init is only called
+// on first Init.
+func (s *service) Init(opts ...Option) {
+	// process options
+	for _, o := range opts {
+		o(&s.opts)
+	}
+
+	s.once.Do(func() {
+		// set cmd name
+		if len(s.opts.Cmd.App().Name) == 0 {
+			s.opts.Cmd.App().Name = s.Server().Options().Name
+		}
+
+		// Initialise the command options
+		if err := s.opts.Cmd.Init(
+			cmd.Auth(&s.opts.Auth),
+			cmd.Broker(&s.opts.Broker),
+			cmd.Registry(&s.opts.Registry),
+			cmd.Runtime(&s.opts.Runtime),
+			cmd.Transport(&s.opts.Transport),
+			cmd.Client(&s.opts.Client),
+			cmd.Config(&s.opts.Config),
+			cmd.Server(&s.opts.Server),
+			cmd.Store(&s.opts.Store),
+			cmd.Profile(&s.opts.Profile),
+		); err != nil {
+			logger.Fatal(err)
+		}
+
+		// execute the command
+		// TODO: do this in service.Run()
+		if err := s.opts.Cmd.Run(); err != nil {
+			logger.Fatal(err)
+		}
+
+		// Explicitly set the table name to the service name
+		name := s.opts.Cmd.App().Name
+		s.opts.Store.Init(store.Table(name))
+	})
+}
+
+func (s *service) Options() Options {
+	return s.opts
+}
+
+func (s *service) Client() client.Client {
+	return s.opts.Client
+}
+
+func (s *service) Server() server.Server {
+	return s.opts.Server
+}
+
+func (s *service) String() string {
+	return "micro"
+}
+
+func (s *service) Start() error {
+	for _, fn := range s.opts.BeforeStart {
+		if err := fn(); err != nil {
+			return err
+		}
+	}
+
+	if err := s.opts.Server.Start(); err != nil {
+		return err
+	}
+
+	for _, fn := range s.opts.AfterStart {
+		if err := fn(); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func (s *service) Stop() error {
+	var gerr error
+
+	for _, fn := range s.opts.BeforeStop {
+		if err := fn(); err != nil {
+			gerr = err
+		}
+	}
+
+	if err := s.opts.Server.Stop(); err != nil {
+		return err
+	}
+
+	for _, fn := range s.opts.AfterStop {
+		if err := fn(); err != nil {
+			gerr = err
+		}
+	}
+
+	return gerr
+}
+
+func (s *service) Run() error {
+	// start the profiler
+	if s.opts.Profile != nil {
+		// to view mutex contention
+		rtime.SetMutexProfileFraction(5)
+		// to view blocking profile
+		rtime.SetBlockProfileRate(1)
+
+		if err := s.opts.Profile.Start(); err != nil {
+			return err
+		}
+		defer s.opts.Profile.Stop()
+	}
+
+	if logger.V(logger.InfoLevel, logger.DefaultLogger) {
+		logger.Infof("Starting [service] %s", s.Name())
+	}
+
+	if err := s.Start(); err != nil {
+		return err
+	}
+
+	ch := make(chan os.Signal, 1)
+	if s.opts.Signal {
+		signal.Notify(ch, signalutil.Shutdown()...)
+	}
+
+	select {
+	// wait on kill signal
+	case <-ch:
+	// wait on context cancel
+	case <-s.opts.Context.Done():
+	}
+
+	return s.Stop()
+}