Diatheke SDK > Sessions > Updating a Session

Updating a Session

In the underlying gRPC API, the UpdateSession method is called using one of several data types to update the session. For the sake of convenience, the SDK provides several functions to handle each type of session update. Updating the session always requires the current session token and will return an updated token with a new action list.

Process ASR Result

When an ASR stream returns a result, it may be used directly to update the session. This is usually called in response to a Wait For User Action. It is the audio equivalent of Process Text.


// Update the session with an ASR result returned previously.
session, err = client.ProcessASRResult(context.Background(), session.Token, result)


# Update the session with an ASR result returned previously.
session = client.process_asr_result(session.token, result)


// Update the session with an ASR result returned previously.
session = client.processASRResult(session.token(), result);


// Update the session with an ASR result returned previously.
client.processASRResult(token: token, asrResult: asrResult) { (sessionOutput) in
	self.token = sessionOutput.token
	self.actionList = sessionOutput.actionList
} failure: { (error) in
	print(error.localizedDescription)
}


SessionInput input = SessionInput.newBuilder()
		.setToken(mToken)
		.setAsr(asrResult)
		.build();
SessionOutput resp = mDiathekeBlockingService.updateSession(input);

Process Text

Text supplied by a user may be used directly to update a session. This is usually called in response to a Wait For User Action.


// Update the session with text.
text := "what's the weather forecast for today"
session, err = client.ProcessText(context.Background(), session.Token, text)


# Update the session with text.
text = "what's the weather forecast for today"
session = client.process_text(session.token, text)


// Update the session with text.
std::string text = "what's the weather forecast for today";
session = client.processText(session.token(), text);


// Update the session with text.
let text = "what's the weather forecast for today"
client.processText(token: token, text: text) { (sessionOutput) in
	self.token = sessionOutput.token
	self.actionList = sessionOutput.actionList
} failure: { (error) in
	print(error.localizedDescription)
}


String text = "what's the weather forcast for today";
TextInput txtMsg = TextInput.newBuilder()
		.setText(text)
		.build();
SessionInput input = SessionInput.newBuilder()
		.setToken(mToken)
		.setText(txtMsg)
		.build();
SessionOutput resp = mDiathekeBlockingService.updateSession(input);

Process Command Result

After receiving a Command Action, the calling application should execute the appropriate business logic, then always update the session with the result.


// Always use the original command ID in the result
result := diathekepb.CommandResult{Id: cmd.Id}

// If there are any output parameters expected by the model,
// add them to the result.
result.OutParameters = map[string]string{"key": "val"}

// If there was a fatal error, set the error message in the result.
result.Error = "I died"

// Update the session with the result
session, err = client.ProcessCommandResult(context.Background(), session.Token, &result)


# Always use the original command ID in the result
result = diatheke.CommandResult(id=cmd.id)

# If there are any output parameters expected by the model,
# add them to the result.
result.out_parameters["key"] = "val"

# If there was a fatal error, set the error message in the result.
result.error = "I died"

# Update the session with the result
session = client.process_command_result(session.token, result)


// Always use the original command ID in the result
cobaltspeech::diatheke::CommandResult result;
result.set_id(cmd.id());

// If there are any output parameters expected by the model,
// add them to the result.
(*result.mutable_out_parameters())["key"] = "val";

// If there was a fatal error, set the error message in the result.
result.set_error("I died");

// Update the session with the result
session = client.processCommandResult(session.token(), result);


// Always use the original command ID in the result
var commandResult = Cobaltspeech_Diatheke_CommandResult()
commandResult.id = commandAction.id

// If there are any output parameters expected by the model,
// add them to the result.
commandResult.outParameters["key"] = "val"

// If there was a fatal error, set the error message in the result.
commandResult.error = "I died"

// Update the session with the result
self.client.processCommandResult(token: token, commandResult: commandResult) { (sessionOutput) in
	self.token = sessionOutput.token
	self.actionList = sessionOutput.actionList
} failure: { (error) in
	print(error.localizedDescription)
}


CommandResult.Builder commandResult = CommandResult.newBuilder();

// Always use the original command ID in the result
commandResult.setId(commandAction.getId());

// If there are any output parameters expected by the model,
// add them to the result.
commandResult.putOutParameters("key", "val");

// If there was a fatal error, set the error message in the result.
commandResult.setError("I died");

// Update the session with the result
SessionInput input = SessionInput.newBuilder()
		.setToken(mToken)
		.setCmd(commandResult.build())
		.build();
SessionOutput resp = mDiathekeBlockingService.updateSession(input);

Set Story

The SetStory method of the API may be used to update a session to begin running from a specified story in the model. This method is particularly useful for implementing system initiated alerts, or to update a session in a mixed UI environment (GUI + voice).

Because this method completely overrides the current session state, it may be called at any time, including in the middle of action list processing.


// The story ID is defined in the Diatheke model.
storyID := "alertStory"

// Set parameters in the updated session's memory (leave empty to
// clear memory).
params := map[string]string{"key": "val"}

// Update the session
session, err = client.SetStory(context.Background(), session.Token, storyID, params)


# The story ID is defined in the Diatheke model
story_id = "alertStory"

# Set parameters in the updated session's memory (leave empty to
# clear memory)
params = {"key": "val"}

# Update the session
session = client.set_story(session.token, story_id, params)


// The story ID is defined in the Diatheke model
std::string storyID = "alertStory";

// Set parameters in the updated session's memory (leave empty to
// clear memory)
std::map<std::string, std::string> params;
params["key"] = "val";

// Update the session
session = client.setStory(session.token(), storyID, params);


// The story ID is defined in the Diatheke model
let storyID = "alertStory"

// Set parameters in the updates session's memory (leave empty to
// clear memory)
let params = ["key" : "val"]

// Update the session
client.setStory(token: token, storyID: storyID, params: params) { (sessionOutput) in
	self.token = sessionOutput.token
	self.actionList = sessionOutput.actionList
} failure: { (error) in
	print(error.localizedDescription)
}


String storyId = "alertStory"
Map<String, String> h = new HashMap<String, String>();
params.put("key","val");

SetStory story = SetStory.newBuilder()
		.setStoryId(storyId)
		.putAllParameters(params)
		.build();
SessionInput input = SessionInput.newBuilder()
		.setToken(mToken)
		.setStory(story)
		.build();
SessionOutput resp = mDiathekeBlockingService.updateSession(input);

If the application wants to return the session to the state it was in before calling this method, it should:

Cache the current session token and action list.
Call this method and run actions from the updated session until there is some indication from the model that the story is complete (e.g., a CommandAction).
Discard the current session token and actions, replacing them with the cached token and actions to resume processing from the previous state.