parent
94dcb738bc
commit
780613d7b9
@ -0,0 +1,68 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type channelService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s channelService) Channel(id string) (geeksbot.Channel, error) {
|
||||||
|
var channel geeksbot.Channel
|
||||||
|
var guild_id string
|
||||||
|
queryString := "SELECT id, guild_id, admin, default_channel, new_patron FROM channels WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&channel.ID, &guild_id, &channel.Admin, &channel.Default, &channel.NewPatron)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Channel{}, err
|
||||||
|
}
|
||||||
|
guild, err := GuildService.Guild(guild_id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Channel{}, err
|
||||||
|
}
|
||||||
|
channel.Guild = guild
|
||||||
|
return channel, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s channelService) CreateChannel(c geeksbot.Channel) (geeksbot.Channel, error) {
|
||||||
|
queryString := "INSERT INTO channels (id, guild_id, admin, default_channel, new_patron VALUES ($1, $2, $3, $4, $5))"
|
||||||
|
_, err := s.db.Exec(queryString, c.ID, c.Guild.ID, c.Admin, c.Default, c.NewPatron)
|
||||||
|
return c, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s channelService) DeleteChannel(c geeksbot.Channel) error {
|
||||||
|
queryString := "DELETE FROM channels WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, c.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s channelService) UpdateChannel(c geeksbot.Channel) (geeksbot.Channel, error) {
|
||||||
|
queryString := "UPDATE channels SET admin = $2, default_channel = $3, new_patron = $4 WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, c.ID, c.Admin, c.Default, c.NewPatron)
|
||||||
|
return c, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s channelService) GuildChannels(g geeksbot.Guild) ([]geeksbot.Channel, error) {
|
||||||
|
var channels []geeksbot.Channel
|
||||||
|
queryString := "SELECT id FROM channels WHERE guild_id = $1"
|
||||||
|
rows, err := s.db.Query(queryString, g.ID)
|
||||||
|
for rows.Next() {
|
||||||
|
var id string
|
||||||
|
err = rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
channel, err := s.Channel(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
channels = append(channels, channel)
|
||||||
|
}
|
||||||
|
return channels, nil
|
||||||
|
}
|
||||||
@ -0,0 +1,100 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type guildService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) Guild(id string) (geeksbot.Guild, error) {
|
||||||
|
var g geeksbot.Guild
|
||||||
|
queryString := "SELECT id, new_patron_message, prefixes FROM guilds WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&g.ID, &g.NewPatronMessage, &g.Prefixes)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Guild{}, err
|
||||||
|
}
|
||||||
|
return g, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) CreateGuild(g geeksbot.Guild) (geeksbot.Guild, error) {
|
||||||
|
queryString := "INSERT INTO guilds (id, new_patron_message, prefixes) VALUES ($1, $2, $3)"
|
||||||
|
_, err := s.db.Exec(queryString, g.ID, g.NewPatronMessage, g.Prefixes)
|
||||||
|
return g, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) DeleteGuild(g geeksbot.Guild) error {
|
||||||
|
queryString := "DELETE FROM guilds WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, g.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) UpdateGuild(g geeksbot.Guild) (geeksbot.Guild, error) {
|
||||||
|
queryString := "UPDATE guilds SET new_patron_message = $2, prefixes = $3 WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, g.ID, g.NewPatronMessage, g.Prefixes)
|
||||||
|
return g, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) GuildRoles(g geeksbot.Guild) ([]geeksbot.Role, error) {
|
||||||
|
var roles []geeksbot.Role
|
||||||
|
queryString := "SELECT id FROM roles WHERE guild_id = $1"
|
||||||
|
rows, err := s.db.Query(queryString, g.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id string
|
||||||
|
err = rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
role, err := s.Role(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
roles = append(roles, role)
|
||||||
|
}
|
||||||
|
return roles, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) CreateRole(r geeksbot.Role) (geeksbot.Role, error) {
|
||||||
|
queryString := "INSERT INTO roles (id, role_type, guild_id) VALUES ($1, $2, $3)"
|
||||||
|
_, err := s.db.Exec(queryString, r.ID, r.RoleType, r.Guild.ID)
|
||||||
|
return r, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) Role(id string) (geeksbot.Role, error) {
|
||||||
|
var role geeksbot.Role
|
||||||
|
var guild_id string
|
||||||
|
queryString := "SELECT id, role_type, guild_id FROM roles WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&role.ID, &role.RoleType, &guild_id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Role{}, err
|
||||||
|
}
|
||||||
|
guild, err := s.Guild(guild_id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Role{}, err
|
||||||
|
}
|
||||||
|
role.Guild = guild
|
||||||
|
return role, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) UpdateRole(r geeksbot.Role) (geeksbot.Role, error) {
|
||||||
|
queryString := "UPDATE roles SET role_type = $2 WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, r.ID, r.RoleType)
|
||||||
|
return r, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s guildService) DeleteRole(r geeksbot.Role) error {
|
||||||
|
queryString := "DELETE FROM roles WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, r.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
@ -0,0 +1,94 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type messageService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s messageService) Message(id string) (geeksbot.Message, error) {
|
||||||
|
var m geeksbot.Message
|
||||||
|
var channel_id string
|
||||||
|
var author_id string
|
||||||
|
queryString := `SELECT m.id, m.created_at, m.modified_at, m.content,
|
||||||
|
m.previous_content, m.channel_id, m.author_id
|
||||||
|
FROM messages as m
|
||||||
|
WHERE m.id = $1`
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&m.ID, &m.CreatedAt, &m.ModifiedAt, &m.Content,
|
||||||
|
&m.PreviousContent, &channel_id, &author_id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Message{}, err
|
||||||
|
}
|
||||||
|
author, err := UserService.User(author_id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Message{}, err
|
||||||
|
}
|
||||||
|
m.Author = author
|
||||||
|
channel, err := ChannelService.Channel(channel_id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Message{}, err
|
||||||
|
}
|
||||||
|
m.Channel = channel
|
||||||
|
return m, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s messageService) CreateMessage(m geeksbot.Message) (geeksbot.Message, error) {
|
||||||
|
queryString := `INSERT INTO messages (id, created_at, content, channel_id, author_id)
|
||||||
|
VALUES ($1, $2, $3, $4, $5)`
|
||||||
|
_, err := s.db.Exec(queryString, m.ID, m.CreatedAt, m.Content, m.Channel.ID, m.Author.ID)
|
||||||
|
return m, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s messageService) UpdateMessage(m geeksbot.Message) (geeksbot.Message, error) {
|
||||||
|
var content string
|
||||||
|
var previousContent []string
|
||||||
|
queryString := "SELECT content, previous_content FROM messages WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, m.ID)
|
||||||
|
err := row.Scan(&content, &previousContent)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Message{}, err
|
||||||
|
}
|
||||||
|
if m.Content != content {
|
||||||
|
previousContent = append(previousContent, content)
|
||||||
|
}
|
||||||
|
queryString = "UPDATE messages SET modified_at = $2, content = $3, previous_content = $4 WHERE id = $1"
|
||||||
|
_, err = s.db.Exec(queryString, m.ID, m.ModifiedAt, m.Content, previousContent)
|
||||||
|
m.PreviousContent = previousContent
|
||||||
|
return m, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s messageService) DeleteMessage(m geeksbot.Message) error {
|
||||||
|
queryString := "DELETE FROM messages WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, m.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s messageService) ChannelMessages(c geeksbot.Channel) ([]geeksbot.Message, error) {
|
||||||
|
var messages []geeksbot.Message
|
||||||
|
queryString := `SELECT id FROM messages WHERE channel_id = $1`
|
||||||
|
rows, err := s.db.Query(queryString, c.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id string
|
||||||
|
err = rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
m, err := s.Message(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
messages = append(messages, m)
|
||||||
|
}
|
||||||
|
return messages, nil
|
||||||
|
}
|
||||||
@ -0,0 +1 @@
|
|||||||
|
ALTER TABLE requests DROP COLUMN guild_id;
|
||||||
@ -0,0 +1,2 @@
|
|||||||
|
ALTER TABLE requests
|
||||||
|
ADD COLUMN guild_id varchar(30) REFERENCES guilds(id) ON DELETE CASCADSE;
|
||||||
@ -0,0 +1,178 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type patreonService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) PatreonCreatorByID(id int) (geeksbot.PatreonCreator, error) {
|
||||||
|
var creator geeksbot.PatreonCreator
|
||||||
|
var gID string
|
||||||
|
queryString := "SELECT id, creator, link, guild_id FROM patreon_creator WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&creator.ID, &creator.Creator, &creator.Link, &gID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonCreator{}, err
|
||||||
|
}
|
||||||
|
guild, err := GuildService.Guild(gID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonCreator{}, err
|
||||||
|
}
|
||||||
|
creator.Guild = guild
|
||||||
|
return creator, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) PatreonCreatorByName(name string, g geeksbot.Guild) (geeksbot.PatreonCreator, error) {
|
||||||
|
var id int
|
||||||
|
queryString := "SELECT id FROM patreon_creator WHERE creator = $1 AND guild_id = $2"
|
||||||
|
err := s.db.QueryRow(queryString, name, g.ID).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonCreator{}, nil
|
||||||
|
}
|
||||||
|
creator, err := s.PatreonCreatorByID(id)
|
||||||
|
return creator, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) CreatePatreonCreator(c geeksbot.PatreonCreator) (geeksbot.PatreonCreator, error) {
|
||||||
|
var id int
|
||||||
|
queryString := `INSERT INTO patreon_creator (creator, link, guild_id) VALUES ($1, $2, $3) RETURNING id`
|
||||||
|
err := s.db.QueryRow(queryString, c.Creator, c.Link, c.Guild.ID).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonCreator{}, err
|
||||||
|
}
|
||||||
|
c.ID = id
|
||||||
|
return c, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) UpdatePatreonCreator(c geeksbot.PatreonCreator) (geeksbot.PatreonCreator, error) {
|
||||||
|
queryString := `UPDATE patreon_creator SET creator = $2, link = $3 WHERE id = $1`
|
||||||
|
_, err := s.db.Exec(queryString, c.ID, c.Creator, c.Link)
|
||||||
|
return c, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) DeletePatreonCreator(c geeksbot.PatreonCreator) error {
|
||||||
|
queryString := `DELETE FROM patreon_creator WHERE id = $1`
|
||||||
|
_, err := s.db.Exec(queryString, c.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) PatreonTierByID(id int) (geeksbot.PatreonTier, error) {
|
||||||
|
var tier geeksbot.PatreonTier
|
||||||
|
var cID int
|
||||||
|
var rID string
|
||||||
|
var next int
|
||||||
|
queryString := `SELECT id, name, description, creator, role, next_tier FROM patreon_tier WHERE id = id`
|
||||||
|
err := s.db.QueryRow(queryString, id).Scan(&tier.ID, &tier.Name, &tier.Description, &cID, &rID, &next)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonTier{}, err
|
||||||
|
}
|
||||||
|
creator, err := s.PatreonCreatorByID(cID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonTier{}, err
|
||||||
|
}
|
||||||
|
tier.Creator = creator
|
||||||
|
role, err := GuildService.Role(rID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonTier{}, err
|
||||||
|
}
|
||||||
|
tier.Role = role
|
||||||
|
if next == -1 {
|
||||||
|
tier.NextTier = nil
|
||||||
|
return tier, nil
|
||||||
|
}
|
||||||
|
nextTier, err := s.PatreonTierByID(next)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonTier{}, err
|
||||||
|
}
|
||||||
|
tier.NextTier = &nextTier
|
||||||
|
return tier, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) PatreonTierByName(name string, creator string) (geeksbot.PatreonTier, error) {
|
||||||
|
var id int
|
||||||
|
queryString := `SELECT id FROM patreon_tier WHERE name = $1 AND creator = $2`
|
||||||
|
err := s.db.QueryRow(queryString, name, creator).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonTier{}, err
|
||||||
|
}
|
||||||
|
tier, err := s.PatreonTierByID(id)
|
||||||
|
return tier, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) CreatePatreonTier(t geeksbot.PatreonTier) (geeksbot.PatreonTier, error) {
|
||||||
|
var id int
|
||||||
|
queryString := `INSERT INTO patreon_tier (name, description, creator, role, next_tier)
|
||||||
|
VALUES ($1, $2, $3, $4, $5) RETURNING id`
|
||||||
|
err := s.db.QueryRow(queryString, t.Name, t.Description, t.Creator.ID, t.Role.ID, t.NextTier.ID).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.PatreonTier{}, err
|
||||||
|
}
|
||||||
|
t.ID = id
|
||||||
|
return t, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) UpdatePatreonTier(t geeksbot.PatreonTier) (geeksbot.PatreonTier, error) {
|
||||||
|
queryString := `UPDATE patreon_tier SET name = $2, description = $3, role = $4, next_tier = $5 WHERE id = $1`
|
||||||
|
_, err := s.db.Exec(queryString, t.ID, t.Name, t.Description, t.Role.ID, t.NextTier.ID)
|
||||||
|
return t, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) DeletePatreonTier(t geeksbot.PatreonTier) error {
|
||||||
|
queryString := `DELETE FROM patreon_tier WHERE id = $1`
|
||||||
|
_, err := s.db.Exec(queryString, t.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) GuildPatreonCreators(g geeksbot.Guild) ([]geeksbot.PatreonCreator, error) {
|
||||||
|
var creators []geeksbot.PatreonCreator
|
||||||
|
queryString := `SELECT id FROM patreon_creator WHERE guild_id = $1`
|
||||||
|
rows, err := s.db.Query(queryString, g.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id int
|
||||||
|
err := rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
creator, err := s.PatreonCreatorByID(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
creators = append(creators, creator)
|
||||||
|
}
|
||||||
|
return creators, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s patreonService) CreatorPatreonTiers(c geeksbot.PatreonCreator) ([]geeksbot.PatreonTier, error) {
|
||||||
|
var tiers []geeksbot.PatreonTier
|
||||||
|
queryString := `SELECT id FROM patreon_tier WHERE creator = $1`
|
||||||
|
rows, err := s.db.Query(queryString, c.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id int
|
||||||
|
err := rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
tier, err := s.PatreonTierByID(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
tiers = append(tiers, tier)
|
||||||
|
}
|
||||||
|
return tiers, nil
|
||||||
|
}
|
||||||
@ -0,0 +1,226 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type requestService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) Request(id int64) (geeksbot.Request, error) {
|
||||||
|
var r geeksbot.Request
|
||||||
|
var aID string
|
||||||
|
var cID string
|
||||||
|
var gID string
|
||||||
|
var uID string
|
||||||
|
var mID string
|
||||||
|
queryString := `SELECT id, author_id, channel_id, guild_id, content, requested_at, completed,
|
||||||
|
completed_at, completed_by, message_id, completed_message
|
||||||
|
WHERE id = $1`
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&r.ID, &aID, &cID, &gID, &r.Content, &r.RequestedAt, &r.Completed,
|
||||||
|
&r.CompletedAt, &uID, &mID, &r.CompletedMessage)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
author, err := UserService.User(aID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
guild, err := GuildService.Guild(gID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
channel, err := ChannelService.Channel(cID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
completedBy, err := UserService.User(uID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
message, err := MessageService.Message(mID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
r.Author = author
|
||||||
|
r.Guild = guild
|
||||||
|
r.Channel = channel
|
||||||
|
r.CompletedBy = completedBy
|
||||||
|
r.Message = message
|
||||||
|
return r, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) UserRequests(u geeksbot.User, completed bool) ([]geeksbot.Request, error) {
|
||||||
|
var requests []geeksbot.Request
|
||||||
|
var queryString string
|
||||||
|
if completed {
|
||||||
|
queryString = "SELECT id FROM requests WHERE author_id = $1"
|
||||||
|
} else {
|
||||||
|
queryString = "SELECT id FROM requests WHERE author_id = $1 AND completed = False"
|
||||||
|
}
|
||||||
|
rows, err := s.db.Query(queryString, u.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id int64
|
||||||
|
err = rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
request, err := s.Request(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
requests = append(requests, request)
|
||||||
|
}
|
||||||
|
return requests, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) GuildRequests(g geeksbot.Guild, completed bool) ([]geeksbot.Request, error) {
|
||||||
|
var requests []geeksbot.Request
|
||||||
|
var queryString string
|
||||||
|
if completed {
|
||||||
|
queryString = "SELECT id FROM requests WHERE guild_id = $1"
|
||||||
|
} else {
|
||||||
|
queryString = "SELECT id FROM requests WHERE guild_id = $1 AND completed = False"
|
||||||
|
}
|
||||||
|
rows, err := s.db.Query(queryString, g.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id int64
|
||||||
|
err = rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
request, err := s.Request(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
requests = append(requests, request)
|
||||||
|
}
|
||||||
|
return requests, nil
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) CreateRequest(r geeksbot.Request) (geeksbot.Request, error) {
|
||||||
|
queryString := `INSERT INTO requests
|
||||||
|
(author_id, channel_id, guild_id, content, requested_at,
|
||||||
|
completed, completed_at, completed_by, message_id, completed_message)
|
||||||
|
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10) RETURNING id`
|
||||||
|
var id int64
|
||||||
|
err := s.db.QueryRow(queryString,
|
||||||
|
r.Author.ID,
|
||||||
|
r.Channel.ID,
|
||||||
|
r.Guild.ID,
|
||||||
|
r.Content,
|
||||||
|
r.RequestedAt,
|
||||||
|
r.Completed,
|
||||||
|
r.CompletedAt,
|
||||||
|
r.CompletedBy.ID,
|
||||||
|
r.Message.ID,
|
||||||
|
r.CompletedMessage).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Request{}, err
|
||||||
|
}
|
||||||
|
r.ID = id
|
||||||
|
return r, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) UpdateRequest(r geeksbot.Request) (geeksbot.Request, error) {
|
||||||
|
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)
|
||||||
|
return r, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) DeleteRequest(r geeksbot.Request) error {
|
||||||
|
queryString := "DELETE FROM requests WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, r.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) Comment(id int64) (geeksbot.Comment, error) {
|
||||||
|
var c geeksbot.Comment
|
||||||
|
var aID string
|
||||||
|
var rID int64
|
||||||
|
queryString := "SELECT id, author_id, request_id, comment_at, content WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&c.ID, &aID, &rID, &c.CommentAt, &c.Content)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Comment{}, err
|
||||||
|
}
|
||||||
|
author, err := UserService.User(aID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Comment{}, err
|
||||||
|
}
|
||||||
|
c.Author = author
|
||||||
|
request, err := s.Request(rID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Comment{}, err
|
||||||
|
}
|
||||||
|
c.Request = request
|
||||||
|
return c, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) RequestComments(r geeksbot.Request) ([]geeksbot.Comment, error) {
|
||||||
|
var comments []geeksbot.Comment
|
||||||
|
queryString := "SELECT id FROM comments WHERE request_id = $1"
|
||||||
|
rows, err := s.db.Query(queryString, r.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id int64
|
||||||
|
err := rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
comment, err := s.Comment(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
comments = append(comments, comment)
|
||||||
|
}
|
||||||
|
return comments, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) RequestCommentCount(r geeksbot.Request) (int, error) {
|
||||||
|
var count int
|
||||||
|
queryString := "SELECT COUNT(id) FROM comments WHERE request_id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, r.ID)
|
||||||
|
err := row.Scan(&count)
|
||||||
|
return count, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) CreateComment(c geeksbot.Comment) (geeksbot.Comment, error) {
|
||||||
|
queryString := `INSERT INTO comments (author_id, request_id, comment_at, content)
|
||||||
|
VALUES ($1, $2, $3, $4) RETURNING id`
|
||||||
|
var id int64
|
||||||
|
err := s.db.QueryRow(queryString, c.Author.ID, c.Request.ID, c.CommentAt, c.Content).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Comment{}, err
|
||||||
|
}
|
||||||
|
c.ID = id
|
||||||
|
return c, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s requestService) DeleteComment(c geeksbot.Comment) error {
|
||||||
|
queryString := "DELETE FROM comments WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, c.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
@ -0,0 +1,138 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type serverService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s serverService) ServerByID(id int) (geeksbot.Server, error) {
|
||||||
|
var server geeksbot.Server
|
||||||
|
var guildID string
|
||||||
|
var aChanID string
|
||||||
|
var iChanID string
|
||||||
|
var iMsgID string
|
||||||
|
var sMsgID string
|
||||||
|
queryString := `SELECT id, name, ip_address, port, password, alerts_channel_id,
|
||||||
|
guild_id, info_channel_id, info_message_id, settings_message_id
|
||||||
|
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, &sMsgID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
guild, err := GuildService.Guild(guildID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
alertChannel, err := ChannelService.Channel(aChanID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
infoChannel, err := ChannelService.Channel(iChanID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
infoMessage, err := MessageService.Message(iMsgID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
settingsMessage, err := MessageService.Message(sMsgID)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
server.Guild = guild
|
||||||
|
server.AlertsChannel = alertChannel
|
||||||
|
server.InfoChannel = infoChannel
|
||||||
|
server.InfoMessage = infoMessage
|
||||||
|
server.SettingsMessage = settingsMessage
|
||||||
|
return server, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s serverService) ServerByName(name string, guild geeksbot.Guild) (geeksbot.Server, error) {
|
||||||
|
var id int
|
||||||
|
queryString := "SELECT id FROM servers WHERE name = $1 AND guild_id = $2"
|
||||||
|
row := s.db.QueryRow(queryString, name, guild.ID)
|
||||||
|
err := row.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
server, err := s.ServerByID(id)
|
||||||
|
return server, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s serverService) CreateServer(server geeksbot.Server) (geeksbot.Server, error) {
|
||||||
|
var id int
|
||||||
|
queryString := `INSERT INTO servers (name, ip_address, port, password, alerts_channel_id,
|
||||||
|
guild_id, info_channel_id, info_message_id, settings_message_id)
|
||||||
|
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9) RETURNING id`
|
||||||
|
err := s.db.QueryRow(queryString,
|
||||||
|
server.Name,
|
||||||
|
server.IPAddr,
|
||||||
|
server.Port,
|
||||||
|
server.Password,
|
||||||
|
server.AlertsChannel,
|
||||||
|
server.Guild,
|
||||||
|
server.InfoChannel,
|
||||||
|
server.InfoMessage,
|
||||||
|
server.SettingsMessage,
|
||||||
|
).Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
return geeksbot.Server{}, err
|
||||||
|
}
|
||||||
|
server.ID = id
|
||||||
|
return server, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s serverService) DeleteServer(server geeksbot.Server) error {
|
||||||
|
queryString := `DELETE FROM servers WHERE id = $1`
|
||||||
|
_, err := s.db.Exec(queryString, server.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s serverService) UpdateServer(server geeksbot.Server) (geeksbot.Server, error) {
|
||||||
|
queryString := `UPDATE servers SET name = $2, ip_address = $3, port = $4, password = $5,
|
||||||
|
alerts_channel_id = $6, info_channel_id = $7, info_message_id = $8,
|
||||||
|
settings_message_id = $9 WHERE id = $1`
|
||||||
|
_, err := s.db.Exec(queryString,
|
||||||
|
server.Name,
|
||||||
|
server.IPAddr,
|
||||||
|
server.Port,
|
||||||
|
server.Password,
|
||||||
|
server.AlertsChannel.ID,
|
||||||
|
server.InfoChannel.ID,
|
||||||
|
server.InfoMessage.ID,
|
||||||
|
server.SettingsMessage.ID,
|
||||||
|
)
|
||||||
|
return server, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s serverService) GuildServers(g geeksbot.Guild) ([]geeksbot.Server, error) {
|
||||||
|
var servers []geeksbot.Server
|
||||||
|
queryString := `SELECT id FROM servers WHERE guild_id = $1`
|
||||||
|
rows, err := s.db.Query(queryString, g.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
for rows.Next() {
|
||||||
|
var id int
|
||||||
|
err = rows.Scan(&id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
server, err := s.ServerByID(id)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
servers = append(servers, server)
|
||||||
|
}
|
||||||
|
return servers, nil
|
||||||
|
}
|
||||||
@ -0,0 +1,37 @@
|
|||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
|
||||||
|
"github.com/dustinpianalto/geeksbot"
|
||||||
|
)
|
||||||
|
|
||||||
|
type userService struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s userService) User(id string) (geeksbot.User, error) {
|
||||||
|
var user geeksbot.User
|
||||||
|
queryString := "SELECT id, steam_id, active, staff, admin WHERE id = $1"
|
||||||
|
row := s.db.QueryRow(queryString, id)
|
||||||
|
err := row.Scan(&user.ID, &user.SteamID, &user.IsActive, &user.IsStaff, &user.IsAdmin)
|
||||||
|
return user, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s userService) CreateUser(u geeksbot.User) (geeksbot.User, error) {
|
||||||
|
queryString := "INSERT INTO users (id, steam_id, active, staff, admin) VALUES ($1, $2, $3, $4, $5)"
|
||||||
|
_, err := s.db.Exec(queryString, u.ID, u.SteamID, u.IsActive, u.IsStaff, u.IsAdmin)
|
||||||
|
return u, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s userService) DeleteUser(u geeksbot.User) error {
|
||||||
|
queryString := "DELETE FROM users WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, u.ID)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s userService) UpdateUser(u geeksbot.User) (geeksbot.User, error) {
|
||||||
|
queryString := "UPDATE users SET steam_id = $2, active = $3, staff = $4, admin = $5 WHERE id = $1"
|
||||||
|
_, err := s.db.Exec(queryString, u.ID, u.SteamID, u.IsActive, u.IsStaff, u.IsAdmin)
|
||||||
|
return u, err
|
||||||
|
}
|
||||||
@ -1,23 +1,19 @@
|
|||||||
package geeksbot
|
package geeksbot
|
||||||
|
|
||||||
import "github.com/bwmarrin/discordgo"
|
|
||||||
|
|
||||||
type Message struct {
|
type Message struct {
|
||||||
ID string
|
ID string
|
||||||
CreatedAt int64
|
CreatedAt int64
|
||||||
ModifiedAt int64
|
ModifiedAt int64
|
||||||
Content string
|
Content string
|
||||||
PreviousContent []string
|
PreviousContent []string
|
||||||
Channel *Channel
|
Channel Channel
|
||||||
Author *User
|
Author User
|
||||||
Embed *discordgo.MessageEmbed
|
|
||||||
PreviousEmbeds []*discordgo.MessageEmbed
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type MessageService interface {
|
type MessageService interface {
|
||||||
Message(id string) (*Message, error)
|
Message(id string) (Message, error)
|
||||||
CreateMessage(m *Message) (*Message, error)
|
CreateMessage(m Message) (Message, error)
|
||||||
DeleteMessage(m *Message) error
|
DeleteMessage(m Message) error
|
||||||
ChannelMessages(c *Channel) ([]*Message, error)
|
ChannelMessages(c Channel) ([]Message, error)
|
||||||
UpdateMessage(m *Message) (*Message, error)
|
UpdateMessage(m Message) (Message, error)
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in new issue