mirror of
https://github.com/opencloud-eu/opencloud.git
synced 2026-04-06 00:23:53 -04:00
105 lines
4.6 KiB
Go
105 lines
4.6 KiB
Go
package jmap
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/opencloud-eu/opencloud/pkg/log"
|
|
)
|
|
|
|
var NS_VACATION = ns(JmapVacationResponse)
|
|
|
|
const (
|
|
vacationResponseId = "singleton"
|
|
)
|
|
|
|
func (j *Client) GetVacationResponse(accountId string, session *Session, ctx context.Context, logger *log.Logger, acceptLanguage string) (VacationResponseGetResponse, SessionState, State, Language, Error) {
|
|
return getTemplate(j, "GetVacationResponse", NS_VACATION, CommandVacationResponseGet,
|
|
func(accountId string, ids []string) VacationResponseGetCommand {
|
|
return VacationResponseGetCommand{AccountId: accountId}
|
|
},
|
|
identity1,
|
|
func(resp VacationResponseGetResponse) State { return resp.State },
|
|
accountId, session, ctx, logger, acceptLanguage, []string{},
|
|
)
|
|
}
|
|
|
|
// Same as VacationResponse but without the id.
|
|
type VacationResponsePayload struct {
|
|
// Should a vacation response be sent if a message arrives between the "fromDate" and "toDate"?
|
|
IsEnabled bool `json:"isEnabled"`
|
|
// If "isEnabled" is true, messages that arrive on or after this date-time (but before the "toDate" if defined) should receive the
|
|
// user's vacation response. If null, the vacation response is effective immediately.
|
|
FromDate time.Time `json:"fromDate,omitzero"`
|
|
// If "isEnabled" is true, messages that arrive before this date-time but on or after the "fromDate" if defined) should receive the
|
|
// user's vacation response. If null, the vacation response is effective indefinitely.
|
|
ToDate time.Time `json:"toDate,omitzero"`
|
|
// The subject that will be used by the message sent in response to messages when the vacation response is enabled.
|
|
// If null, an appropriate subject SHOULD be set by the server.
|
|
Subject string `json:"subject,omitempty"`
|
|
// The plaintext body to send in response to messages when the vacation response is enabled.
|
|
// If this is null, the server SHOULD generate a plaintext body part from the "htmlBody" when sending vacation responses
|
|
// but MAY choose to send the response as HTML only. If both "textBody" and "htmlBody" are null, an appropriate default
|
|
// body SHOULD be generated for responses by the server.
|
|
TextBody string `json:"textBody,omitempty"`
|
|
// The HTML body to send in response to messages when the vacation response is enabled.
|
|
// If this is null, the server MAY choose to generate an HTML body part from the "textBody" when sending vacation responses
|
|
// or MAY choose to send the response as plaintext only.
|
|
HtmlBody string `json:"htmlBody,omitempty"`
|
|
}
|
|
|
|
func (j *Client) SetVacationResponse(accountId string, vacation VacationResponsePayload, session *Session, ctx context.Context, logger *log.Logger, acceptLanguage string) (VacationResponse, SessionState, State, Language, Error) {
|
|
logger = j.logger("SetVacationResponse", session, logger)
|
|
|
|
cmd, err := j.request(session, logger, NS_VACATION,
|
|
invocation(CommandVacationResponseSet, VacationResponseSetCommand{
|
|
AccountId: accountId,
|
|
Create: map[string]VacationResponse{
|
|
vacationResponseId: {
|
|
IsEnabled: vacation.IsEnabled,
|
|
FromDate: vacation.FromDate,
|
|
ToDate: vacation.ToDate,
|
|
Subject: vacation.Subject,
|
|
TextBody: vacation.TextBody,
|
|
HtmlBody: vacation.HtmlBody,
|
|
},
|
|
},
|
|
}, "0"),
|
|
// chain a second request to get the current complete VacationResponse object
|
|
// after performing the changes, as that makes for a better API
|
|
invocation(CommandVacationResponseGet, VacationResponseGetCommand{AccountId: accountId}, "1"),
|
|
)
|
|
if err != nil {
|
|
return VacationResponse{}, "", "", "", err
|
|
}
|
|
return command(j.api, logger, ctx, session, j.onSessionOutdated, cmd, acceptLanguage, func(body *Response) (VacationResponse, State, Error) {
|
|
var setResponse VacationResponseSetResponse
|
|
err = retrieveResponseMatchParameters(logger, body, CommandVacationResponseSet, "0", &setResponse)
|
|
if err != nil {
|
|
return VacationResponse{}, "", err
|
|
}
|
|
|
|
setErr, notok := setResponse.NotCreated[vacationResponseId]
|
|
if notok {
|
|
// this means that the VacationResponse was not updated
|
|
logger.Error().Msgf("%T.NotCreated contains an error: %v", setResponse, setErr)
|
|
return VacationResponse{}, "", setErrorError(setErr, VacationResponseType)
|
|
}
|
|
|
|
var getResponse VacationResponseGetResponse
|
|
err = retrieveResponseMatchParameters(logger, body, CommandVacationResponseGet, "1", &getResponse)
|
|
if err != nil {
|
|
return VacationResponse{}, "", err
|
|
}
|
|
|
|
if len(getResponse.List) != 1 {
|
|
berr := fmt.Errorf("failed to find %s in %s response", string(VacationResponseType), string(CommandVacationResponseGet))
|
|
logger.Error().Msg(berr.Error())
|
|
return VacationResponse{}, "", jmapError(berr, JmapErrorInvalidJmapResponsePayload)
|
|
}
|
|
|
|
return getResponse.List[0], setResponse.NewState, nil
|
|
})
|
|
}
|