set_hook_query_builder.go

package t38c

import (
	"context"
	"strconv"
	"strings"
)

// SetHookQueryBuilder struct
type SetHookQueryBuilder struct {
	client     tile38Client
	name       string
	endpoints  []string
	cmd        cmd
	metas      []Meta
	expiration *int
}

func newSetHookQueryBuilder(client tile38Client, name, endpoint string, query cmd) SetHookQueryBuilder {
	return SetHookQueryBuilder{
		client:    client,
		name:      name,
		endpoints: []string{endpoint},
		cmd:       query,
	}
}

func (query SetHookQueryBuilder) toCmd() cmd {
	args := []string{query.name, strings.Join(query.endpoints, ",")}
	for _, meta := range query.metas {
		args = append(args, "META", meta.Name, meta.Value)
	}

	if query.expiration != nil {
		args = append(args, "EX", strconv.Itoa(*query.expiration))
	}

	args = append(args, query.cmd.Name)
	args = append(args, query.cmd.Args...)
	return newCmd("SETHOOK", args...)
}

// Do cmd
func (query SetHookQueryBuilder) Do(ctx context.Context) error {
	cmd := query.toCmd()
	return query.client.jExecute(ctx, nil, cmd.Name, cmd.Args...)
}

// Endpoint appends new endpoint to the hook.
// Tile38 will try to send a message to the first endpoint.
// If the send is a failure then the second endpoint is tried, and so on.
func (query SetHookQueryBuilder) Endpoint(endpoint string) SetHookQueryBuilder {
	query.endpoints = append(query.endpoints, endpoint)
	return query
}

// Expiration set the specified expire time, in seconds.
func (query SetHookQueryBuilder) Expiration(seconds int) SetHookQueryBuilder {
	query.expiration = &seconds
	return query
}

// Meta ...
func (query SetHookQueryBuilder) Meta(name, value string) SetHookQueryBuilder {
	query.metas = append(query.metas, Meta{name, value})
	return query
}