mirror of
https://github.com/grassrootseconomics/farmstar-survey-backend.git
synced 2024-12-13 19:46:09 +01:00
45 lines
973 B
Go
45 lines
973 B
Go
|
package hooks
|
||
|
|
||
|
import (
|
||
|
"fmt"
|
||
|
|
||
|
"github.com/grassrootseconomics/farmstar-survey-backend/internal/worker"
|
||
|
"github.com/pocketbase/pocketbase/core"
|
||
|
)
|
||
|
|
||
|
func (r *HooksContainer) bootstrapFarmerHook() {
|
||
|
r.pb.OnModelAfterCreate("farmer_farm").Add(func(e *core.ModelEvent) error {
|
||
|
farmerRecord, err := r.pb.Dao().FindRecordById("farmer_farm", e.Model.GetId())
|
||
|
if err != nil {
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
userRecord, err := r.pb.Dao().FindRecordById("users", farmerRecord.GetString("user"))
|
||
|
if err != nil {
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
phone := userRecord.GetString("phone")
|
||
|
|
||
|
msg := fmt.Sprintf(
|
||
|
"New farmer's survey completed:\n\nname: %s\nphone: %s",
|
||
|
userRecord.GetString("name"),
|
||
|
phone,
|
||
|
)
|
||
|
|
||
|
if err := r.worker.QueueSMSTask(phone, worker.FarmerComplete, ""); err != nil {
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
if err := r.worker.QueueTgTask(msg); err != nil {
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
if err := r.worker.QueueRewardsTask(phone, 130_000_000); err != nil {
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
return nil
|
||
|
})
|
||
|
}
|