database

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 12, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateCampaign

func CreateCampaign(name, poolAddress string, startTime, endTime int64) (int, error)

func CreateOnboardingTask

func CreateOnboardingTask(campaignID int, description string, onboardingReward float64, onboardingThreshold float64, startTime, endTime int64) (int, error)

func CreateSharePoolTask

func CreateSharePoolTask(campaignID int, description string, pointsPool float64, startTime, endTime int64) (int, error)

func CreateTask

func CreateTask(campaignID int, taskType, description string, onboardingReward float64, onboardingThreshold float64, pointsPool float64, startTime, endTime int64) (int, error)

func CreateUser

func CreateUser(address string) (int, error)

func CreateUserPointsHistory

func CreateUserPointsHistory(userID, taskID, campaignID int, points float64) error

func CreateUserTask

func CreateUserTask(userID, taskID int, completed bool, amount, points float64) (int, error)

func GetActiveCampaignAddresses

func GetActiveCampaignAddresses() ([]string, error)

func GetOrCreateUserID

func GetOrCreateUserID(address string) (int, error)

func IncreaseUserTaskAmount

func IncreaseUserTaskAmount(taskID int, userID int, amount float64) error

func InitPostgreSQL

func InitPostgreSQL() *sql.DB

func InsertSwapEvent

func InsertSwapEvent(userID int, poolAddress string, usdc float64, swapTime int64, txHash string) error

func UpdateUserTask

func UpdateUserTask(userTaskID int, completed bool, amount, points float64) error

func UpdateUserTaskByUserIDTaskID

func UpdateUserTaskByUserIDTaskID(userID, taskID int, completed bool, amount, points float64) error

Types

type Campaign

type Campaign struct {
	CampaignID  int
	Name        string
	PoolAddress string
	StartTime   int64
	EndTime     int64
	CreatedAt   int64
	UpdatedAt   int64
}

func GetCampaignByID

func GetCampaignByID(id int) (*Campaign, error)

func GetCampaignsByAddress

func GetCampaignsByAddress(address string) ([]Campaign, error)

type DBConfig

type DBConfig struct {
	Host     string
	Port     int
	User     string
	Password string
	DBName   string
}

type Task

type Task struct {
	TaskID              int
	CampaignID          int
	Type                string
	Description         string
	OnboardingReward    float64
	OnboardingThreshold float64
	PointsPool          float64
	StartTime           int64
	EndTime             int64
	CreatedAt           int64
	UpdatedAt           int64
}

func GetActiveTasksByCampaignID

func GetActiveTasksByCampaignID(campaignID int, timestamp int64) ([]Task, error)

func GetExpiredSharePoolTasks

func GetExpiredSharePoolTasks(now int64, lastCheckTime int64) ([]Task, error)

func GetOnboardingTaskByCampaignID

func GetOnboardingTaskByCampaignID(campaignID int) (*Task, error)

func GetTasksByCampaignID

func GetTasksByCampaignID(campaignID int) ([]Task, error)

func GetTasksByTaskIDs

func GetTasksByTaskIDs(taskIDs []int) ([]Task, error)

type User

type User struct {
	UserID    int
	Address   string
	CreatedAt int64
}

func GetUserByAddress

func GetUserByAddress(address string) (*User, error)

func GetUserByID

func GetUserByID(userID int) (*User, error)

type UserPointsHistory

type UserPointsHistory struct {
	HistoryID  int
	UserID     int
	TaskID     int
	CampaignID int
	Points     float64
	CreatedAt  int64
}

func GetUserPointsHistoryByUserID

func GetUserPointsHistoryByUserID(userID int) ([]UserPointsHistory, error)

type UserSwap

type UserSwap struct {
	SwapID          int
	UserID          int
	TransactionHash string
	PoolAddress     string
	AmountUSDC      float64
	AmountWETH      float64
	SwapTime        int64
	CreatedAt       int64
}

type UserTask

type UserTask struct {
	UserTaskID int
	UserID     int
	TaskID     int
	Completed  bool
	Amount     float64
	Points     float64
	CreatedAt  int64
	UpdatedAt  int64
}

func GetOrCreateOnboardingUserTask

func GetOrCreateOnboardingUserTask(userID, taskID int) (UserTask, error)

func GetUserTaskByUserIDTaskID

func GetUserTaskByUserIDTaskID(userID, taskID int) (UserTask, error)

func GetUserTasksByUserID

func GetUserTasksByUserID(userID int) ([]UserTask, error)

func GetUserTasksByUserIDTaskIDs

func GetUserTasksByUserIDTaskIDs(userID int, taskIDs []int) ([]UserTask, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL