framework/queue/config.go at v1.17.2 · goravel/framework · 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
package queue

import (
	"fmt"

	contractsconfig "github.com/goravel/framework/contracts/config"
)

type Config struct {
	contractsconfig.Config

	appName           string
	defaultConnection string
	defaultQueue      string
	failedDatabase    string
	failedTable       string
	defaultConcurrent int
	debug             bool
}

func NewConfig(config contractsconfig.Config) *Config {
	defaultConnection := config.GetString("queue.default")
	defaultQueue := config.GetString(fmt.Sprintf("queue.connections.%s.queue", defaultConnection), "default")
	defaultConcurrent := max(config.GetInt(fmt.Sprintf("queue.connections.%s.concurrent", defaultConnection), 1), 1)

	c := &Config{
		Config: config,

		appName:           config.GetString("app.name", "goravel"),
		debug:             config.GetBool("app.debug"),
		defaultConnection: defaultConnection,
		defaultQueue:      defaultQueue,
		defaultConcurrent: defaultConcurrent,
		failedDatabase:    config.GetString("queue.failed.database"),
		failedTable:       config.GetString("queue.failed.table"),
	}

	return c
}

func (r *Config) Debug() bool {
	return r.debug
}

func (r *Config) DefaultConnection() string {
	return r.defaultConnection
}

func (r *Config) DefaultQueue() string {
	return r.defaultQueue
}

func (r *Config) DefaultConcurrent() int {
	return r.defaultConcurrent
}

func (r *Config) Driver(connection string) string {
	return r.GetString(fmt.Sprintf("queue.connections.%s.driver", connection))
}

func (r *Config) FailedDatabase() string {
	return r.failedDatabase
}

func (r *Config) FailedTable() string {
	return r.failedTable
}

func (r *Config) Via(connection string) any {
	return r.Get(fmt.Sprintf("queue.connections.%s.via", connection))
}