hyeoncheon / uart / 129

Committed 16 Jul 2022 08:32AM UTC coverage: 75.776%. First build

Build # 129

Build Type

Pull #13

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/hyeoncheon/uart/commit/<a class=hub.com/hyeoncheon/uart/commit/f6387ffdbcb0f9fb7da1afa4d4f4c86cd7153ad0">f6387ffdb<a href="https://github.com/hyeoncheon/uart/commit/f6387ffdbcb0f9fb7da1afa4d4f4c86cd7153ad0">">Merge </a><a class="double-link" href="https://github.com/hyeoncheon/uart/commit/<a class="double-link" href="https://github.com/hyeoncheon/uart/commit/7a0efe4b5d38fcf66487104c805aebcaa8c9cc50">7a0efe4b5</a>">7a0efe4b5</a><a href="https://github.com/hyeoncheon/uart/commit/f6387ffdbcb0f9fb7da1afa4d4f4c86cd7153ad0"> into 79671e44b">79671e44b</a>

Pull Request Pull Request #13: Upgrade buffalo and modules

Run Details

14 of 14 new or added lines in 7 files covered. (100.0%)

2124 of 2803 relevant lines covered (75.78%)

39.06 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

60.0

/jobs/jobs.go

package jobs

import (
        "reflect"
        "strconv"
        "strings"

        "github.com/gobuffalo/buffalo"
        "github.com/gobuffalo/buffalo/worker"
)

// constants
const (
        DefaultQueue = "default"
)

// Handler is structure storing handler statistics data
type Handler struct {
        Name    string
        Running int
        Success int
}

func (h Handler) String() string {
        return h.Name + " " + strconv.Itoa(h.Success) + "/" + strconv.Itoa(h.Running)
}

// Handlers is a handler registry (originally a dummy type for holding methods)
type Handlers map[string]*Handler

var handlers = Handlers{}
var env string
var w worker.Worker
var logger buffalo.Logger

// RegisterAll register all workers
func RegisterAll(app *buffalo.App) {
        env = app.Env
        w = app.Worker
        logger = app.Logger.WithField("category", "worker")

        x := reflect.TypeOf(&Handler{})
        for i := 0; i < x.NumMethod(); i++ {
                method := x.Method(i)
                if !strings.HasPrefix(method.Name, "Register") {
                        continue
                }
                logger.Debugf("invoking %v...", method.Name)

                h := Handler{Name: method.Name}
                r := method.Func.Call([]reflect.Value{reflect.ValueOf(&h)})
                if err := r[0].Interface(); err != nil {
                        logger.Error("OOPS! registration failed: ", handlers[method.Name])
                }
                handlers[h.Name] = &h
                logger.Infof("new background job handler %v registered", h)
        }
        logger.Infof("jobs registration completed! (%v handlers)", len(handlers))
}

func countRunning(name string) {
        if h, ok := handlers[name]; ok {
                h.Running++
        }
}

func countSuccess(name string) {
        if h, ok := handlers[name]; ok {
                h.Success++
        }
}

func printStatistics(name string) {
        if h, ok := handlers[name]; ok {
                logger.Infof("statistics: %v", h)
        }
}

1	package jobs
2
3	import (
4	"reflect"
5	"strconv"
6	"strings"
7
8	"github.com/gobuffalo/buffalo"
9	"github.com/gobuffalo/buffalo/worker"
10	)
11
12	// constants
13	const (
14	DefaultQueue = "default"
15	)
16
17	// Handler is structure storing handler statistics data
18	type Handler struct {
19	Name string
20	Running int
21	Success int
22	}
23
24	func (h Handler) String() string {	4✔
25	return h.Name + " " + strconv.Itoa(h.Success) + "/" + strconv.Itoa(h.Running)	4✔
26	}	4✔
27
28	// Handlers is a handler registry (originally a dummy type for holding methods)
29	type Handlers map[string]*Handler
30
31	var handlers = Handlers{}
32	var env string
33	var w worker.Worker
34	var logger buffalo.Logger
35
36	// RegisterAll register all workers
37	func RegisterAll(app *buffalo.App) {	2✔
38	env = app.Env	2✔
39	w = app.Worker	2✔
40	logger = app.Logger.WithField("category", "worker")	2✔
41		2✔
42	x := reflect.TypeOf(&Handler{})	2✔
43	for i := 0; i < x.NumMethod(); i++ {	8✔
44	method := x.Method(i)	6✔
45	if !strings.HasPrefix(method.Name, "Register") {	8✔
46	continue	2✔
47	}
48	logger.Debugf("invoking %v...", method.Name)	4✔
49		4✔
50	h := Handler{Name: method.Name}	4✔
51	r := method.Func.Call([]reflect.Value{reflect.ValueOf(&h)})	4✔
52	if err := r[0].Interface(); err != nil {	4✔
53	logger.Error("OOPS! registration failed: ", handlers[method.Name])	×
54	}	×
55	handlers[h.Name] = &h	4✔
56	logger.Infof("new background job handler %v registered", h)	4✔
57	}
58	logger.Infof("jobs registration completed! (%v handlers)", len(handlers))	2✔
59	}
60
61	func countRunning(name string) {	×
62	if h, ok := handlers[name]; ok {	×
63	h.Running++	×
64	}	×
65	}
66
67	func countSuccess(name string) {	×
68	if h, ok := handlers[name]; ok {	×
69	h.Success++	×
70	}	×
71	}
72
73	func printStatistics(name string) {	×
74	if h, ok := handlers[name]; ok {	×
75	logger.Infof("statistics: %v", h)	×
76	}	×
77	}

hyeoncheon / uart / 129

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous