mormor/main.go at master · knakk/mormor · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
package main

import (
	"flag"
	"fmt"
	"html/template"
	"log"
	"os"
	"os/signal"
	"syscall"
)

// globals
var (
	templates = template.Must(template.ParseGlob("templates/*.html"))
)

// mormorMain represents the main program execution.
type mormorMain struct {
	metadata *metadataService
	enduser  *enduserService
}

func (m *mormorMain) Run() {

	interrupt := make(chan os.Signal, 1)
	errors := make(chan error)

	signal.Notify(interrupt, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)

	log.Println("Mormor is starting.")

	go func() {
		if err := m.metadata.Start(); err != nil {
			errors <- fmt.Errorf("error starting metadata service: %v", err)
		}
	}()

	go func() {
		if err := m.enduser.Start(); err != nil {
			errors <- fmt.Errorf("error starting enduser service: %v", err)
		}
	}()

	select {
	case <-interrupt:
		break
	case err := <-errors:
		log.Println(err)
		break
	}

	signal.Stop(interrupt)

	log.Println("Mormor is shutting down.")

	if err := m.enduser.Stop(); err != nil {
		log.Printf("error stopping enduser service: %v", err)
	}

	if err := m.metadata.Stop(); err != nil {
		log.Printf("error stopping metadata service: %v", err)
	}

}

func newMormorMain(ms *metadataService, es *enduserService) *mormorMain {
	return &mormorMain{
		metadata: ms,
		enduser:  es,
	}
}

func main() {

	var (
		enduserAddr  = flag.String("enduser-addr", ":7000", "end-user service listening address")
		enduserLang  = flag.String("enduser-lang", "no", "end-user default language(s)")
		metadataAddr = flag.String("metadata-addr", ":7001", "metadata service listening address")
		metadataDB   = flag.String("metadata-db", "metadata.db", "metadata database")
		metadataNS   = flag.String("metadata-ns", "", "metadata namespace (RDF resource base URI)")
		//adminAddr    = flag.String("admin-addr", ":7007", "admin interface listening address")
	)

	flag.Parse()

	metadata := newMetadataService(*metadataAddr, *metadataDB, *metadataNS)
	metadata.searchService = newSearchService(*enduserLang)
	enduser := newEndUserService(*enduserAddr, *enduserLang, metadata)

	m := newMormorMain(metadata, enduser)

	m.Run()
}