add.go

func message_new() (hnd eventHandler, name string, stmt string) {
    type newMessage struct {
        Date json.Number `json:"date"`
        UserId json.Number `json:"user_id"`
    }
    table := config.GetDbConfig().Database + ".event_message_new"
    name = "message_new"
    stmt = "insert into " + table + "(groupid,timestamp,sender,unique_key,amount) VALUES($1,$2,$3,$4,1) on conflict(unique_key) DO UPDATE SET amount=event_message_new.amount + 1;"
    hnd = func (groupid string, object json.RawMessage, inserter database.EventInserter) error {
        var nm newMessage
        err := json.Unmarshal(object, &nm)
        if err != nil {
            fmt.Println("Event object error ", err)
            return errors.New("parse error")
        }
        d := string(nm.Date)
        u := string(nm.UserId)
        err1 := inserter(name, groupid, d, u, groupid + "_" + u)
        return err1
    }
    return
}