hasb

type DeleteQuery struct {
	TableName    string
	Where        *ExpressionTree
	Returning    []string
	AffectedRows bool
}

type EventDetails struct {
	SessionAttributes map[string]interface{} `json:"session_variables"`
	Op                string                 `json:"op"`
	RowChange         RowChange              `json:"data"`
}

type EventPayload struct {
	Event     EventDetails  `json:"event"`
	CreatedAt time.Time     `json:"created_at"`
	Id        uuid.UUID     `json:"id"`
	Table     TableMetadata `json:"table"`
}

type EventTrigger struct {
	Name string `json:"name"`
}

type ExpressionTree struct {
	Left  *ExpressionTree
	Right *ExpressionTree
	Val   string
	In    string
}

type ExpressionTreeBuilder struct {
	// contains filtered or unexported fields
}

type GetQuery struct {
	// contains filtered or unexported fields
}

type GetQueryTable struct {
	Name    string
	Where   *ExpressionTree
	Objects []string
}

type InsertQuery struct {
	TableName    string
	Objects      map[string]string
	Returning    []string
	AffectedRows bool
}

type MInnerResp struct {
	AffectedRows int                      `json:"affected_rows"`
	Returning    []map[string]interface{} `json:"returning"`
}

type MResp map[string]MInnerResp

type MutationQuery struct {
	UpdateQueries []UpdateQuery
	InsertQueries []InsertQuery
	DeleteQueries []DeleteQuery
}

type QResp map[string][]map[string]interface{}

type Query struct {
	Vars map[string]interface{}

	MutationQueries []MutationQuery
	// contains filtered or unexported fields
}

type RowChange struct {
	OldRow map[string]interface{} `json:"old"`
	NewRow map[string]interface{} `json:"new"`
}

type TableMetadata struct {
	Schema string `json:"schema"`
	Name   string `json:"name"`
}

type UpdateQuery struct {
	TableName    string
	Where        *ExpressionTree
	Set          map[string]string
	Returning    []string
	AffectedRows bool
}