79 lines
1.6 KiB
Go
79 lines
1.6 KiB
Go
package ttv
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/adeithe/go-twitch/api"
|
|
"zomo.dev/largehadroncollider/db"
|
|
"zomo.dev/largehadroncollider/util"
|
|
)
|
|
|
|
// sign in to twitch with each saved tokens
|
|
|
|
func initAuth(conf *util.Config, dbConn *db.DBConn) (*TwitchAuth, error) {
|
|
ctx := context.Background()
|
|
|
|
tokens, err := getTokensFromDB(dbConn)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
client := api.New(conf.ClientID)
|
|
|
|
accounts, err := testTokens(ctx, client, tokens)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &TwitchAuth{ ctx, client, accounts }, nil
|
|
}
|
|
|
|
type TwitchAuth struct {
|
|
Ctx context.Context
|
|
Client *api.Client
|
|
Accounts []TwitchAuthAccount
|
|
}
|
|
|
|
type TwitchAuthAccount struct {
|
|
api.User
|
|
Token string
|
|
}
|
|
|
|
func getTokensFromDB(dbConn *db.DBConn) ([]string, error) {
|
|
// TODO db cold
|
|
return []string{}, nil
|
|
}
|
|
|
|
func testTokens(ctx context.Context, client *api.Client, tokens []string) ([]TwitchAuthAccount, error) {
|
|
accounts := make([]TwitchAuthAccount, 0)
|
|
for _, token := range tokens {
|
|
account, err := testToken(ctx, client, token)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
accounts = append(accounts, account)
|
|
}
|
|
return accounts, nil
|
|
}
|
|
|
|
func testToken(ctx context.Context, client *api.Client, token string) (TwitchAuthAccount, error) {
|
|
users, err := client.Users.List().Do(ctx, api.WithBearerToken(token))
|
|
if err != nil {
|
|
return TwitchAuthAccount{}, err
|
|
}
|
|
|
|
usersData := users.Data
|
|
|
|
if len(usersData) <= 0 {
|
|
return TwitchAuthAccount{}, errors.New("user data returned an empty array")
|
|
}
|
|
|
|
mainUser := usersData[0]
|
|
|
|
return TwitchAuthAccount{
|
|
mainUser,
|
|
token,
|
|
}, nil
|
|
}
|