Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
53dc44abda | ||
|
|
6262ebfeb4 | ||
|
|
005dfc815f |
@@ -28,6 +28,7 @@ func main() {
|
||||
}
|
||||
|
||||
database.ConnectDatabase(os.Getenv("DATABASE_URL"))
|
||||
database.RunMigrations()
|
||||
services.InitializeServices()
|
||||
|
||||
owners := []string{
|
||||
|
||||
@@ -23,10 +23,6 @@ var (
|
||||
)
|
||||
|
||||
func ConnectDatabase(dbConnString string) {
|
||||
s := bindata.Resource(migrations.AssetNames(),
|
||||
func(name string) ([]byte, error) {
|
||||
return migrations.Asset(name)
|
||||
})
|
||||
var err error
|
||||
db, err = sql.Open("postgres", dbConnString)
|
||||
if err != nil {
|
||||
@@ -36,6 +32,15 @@ func ConnectDatabase(dbConnString string) {
|
||||
db.SetMaxOpenConns(75)
|
||||
db.SetMaxIdleConns(5)
|
||||
db.SetConnMaxLifetime(300)
|
||||
initServices()
|
||||
log.Println("Services Initialized")
|
||||
}
|
||||
|
||||
func RunMigrations() {
|
||||
s := bindata.Resource(migrations.AssetNames(),
|
||||
func(name string) ([]byte, error) {
|
||||
return migrations.Asset(name)
|
||||
})
|
||||
d, err := bindata.WithInstance(s)
|
||||
if err != nil {
|
||||
log.Fatal(fmt.Errorf("cannot load migrations: %w", err))
|
||||
@@ -57,8 +62,7 @@ func ConnectDatabase(dbConnString string) {
|
||||
}
|
||||
}
|
||||
log.Println("Migrations Run")
|
||||
initServices()
|
||||
log.Println("Services Initialized")
|
||||
|
||||
}
|
||||
|
||||
func initServices() {
|
||||
|
||||
@@ -154,7 +154,7 @@ func (s requestService) UpdateRequest(r geeksbot.Request) (geeksbot.Request, err
|
||||
queryString := `UPDATE requests SET
|
||||
completed = $2, completed_at = $3, completed_by = $4, completed_message = $5
|
||||
WHERE id = $1`
|
||||
_, err := s.db.Exec(queryString, r.ID, r.Completed, r.CompletedAt, r.CompletedBy, r.CompletedMessage)
|
||||
_, err := s.db.Exec(queryString, r.ID, r.Completed, r.CompletedAt, r.CompletedBy.ID, r.CompletedMessage)
|
||||
return r, err
|
||||
}
|
||||
|
||||
|
||||
@@ -24,7 +24,7 @@ func (s serverService) ServerByID(id int) (geeksbot.Server, error) {
|
||||
FROM servers WHERE id = $1`
|
||||
row := s.db.QueryRow(queryString, id)
|
||||
err := row.Scan(&server.ID, &server.Name, &server.IPAddr, &server.Port, &server.Password,
|
||||
&aChanID, &guildID, &iChanID, &iMsgID, &server.FTPPort, &server.FTPUser, &server.FTPPass, &sMsgID)
|
||||
&aChanID, &guildID, &iChanID, &iMsgID, &sMsgID, &server.FTPPort, &server.FTPUser, &server.FTPPass)
|
||||
if err != nil {
|
||||
return geeksbot.Server{}, err
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user