#169

pending completion

Build # #169

Build Type

push

github-actions

Committed by

web-flow

Commit Message

Remove use of deprecated API (#1758)

Run Details

4 of 4 new or added lines in 1 file covered. (100.0%)

17345 of 21558 relevant lines covered (80.46%)

0.8 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.92

/temporal-sdk/src/main/java/io/temporal/internal/sync/BaseRootWorkflowInboundCallsInterceptor.java

/*
 * Copyright (C) 2022 Temporal Technologies, Inc. All Rights Reserved.
 *
 * Copyright (C) 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 * Modifications copyright (C) 2017 Uber Technologies, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this material except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package io.temporal.internal.sync;

import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
import io.temporal.common.interceptors.WorkflowOutboundCallsInterceptor;
import javax.annotation.Nonnull;

/**
 * Provides core functionality for a root WorkflowInboundCallsInterceptor that is reused by specific
 * root RootWorkflowInboundCallsInterceptor implementations inside {@link
 * DynamicSyncWorkflowDefinition} and {@link POJOWorkflowImplementationFactory}
 *
 * <p>Root {@code WorkflowInboundCallsInterceptor} is an interceptor that should be at the end of
 * the {@link WorkflowInboundCallsInterceptor} interceptors chain and which encapsulates calls into
 * Temporal internals while providing a WorkflowInboundCallsInterceptor interface for chaining on
 * top of it.
 */
public abstract class BaseRootWorkflowInboundCallsInterceptor
    implements WorkflowInboundCallsInterceptor {
  protected final SyncWorkflowContext workflowContext;

  public BaseRootWorkflowInboundCallsInterceptor(SyncWorkflowContext workflowContext) {
    this.workflowContext = workflowContext;
  }

  @Override
  public void init(WorkflowOutboundCallsInterceptor outboundCalls) {
    workflowContext.initHeadOutboundCallsInterceptor(outboundCalls);
  }

  @Override
  public void handleSignal(SignalInput input) {
    workflowContext.handleInterceptedSignal(input);
  }

  @Override
  public QueryOutput handleQuery(QueryInput input) {
    return workflowContext.handleInterceptedQuery(input);
  }

  @Override
  public void validateUpdate(UpdateInput input) {
    workflowContext.handleInterceptedValidateUpdate(input);
  }

  @Override
  public UpdateOutput executeUpdate(UpdateInput input) {
    return workflowContext.handleInterceptedExecuteUpdate(input);
  }

  @Nonnull
  @Override
  public Object newWorkflowMethodThread(Runnable runnable, String name) {
    return workflowContext.newWorkflowMethodThreadIntercepted(runnable, name);
  }

  @Nonnull
  @Override
  public Object newCallbackThread(Runnable runnable, String name) {
    return workflowContext.newWorkflowCallbackThreadIntercepted(runnable, name);
  }
}

1	/*
2	* Copyright (C) 2022 Temporal Technologies, Inc. All Rights Reserved.
3	*
4	* Copyright (C) 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
5	*
6	* Modifications copyright (C) 2017 Uber Technologies, Inc.
7	*
8	* Licensed under the Apache License, Version 2.0 (the "License");
9	* you may not use this material except in compliance with the License.
10	* You may obtain a copy of the License at
11	*
12	* http://www.apache.org/licenses/LICENSE-2.0
13	*
14	* Unless required by applicable law or agreed to in writing, software
15	* distributed under the License is distributed on an "AS IS" BASIS,
16	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17	* See the License for the specific language governing permissions and
18	* limitations under the License.
19	*/
20
21	package io.temporal.internal.sync;
22
23	import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
24	import io.temporal.common.interceptors.WorkflowOutboundCallsInterceptor;
25	import javax.annotation.Nonnull;
26
27	/**
28	* Provides core functionality for a root WorkflowInboundCallsInterceptor that is reused by specific
29	* root RootWorkflowInboundCallsInterceptor implementations inside {@link
30	* DynamicSyncWorkflowDefinition} and {@link POJOWorkflowImplementationFactory}
31	*
32	* <p>Root {@code WorkflowInboundCallsInterceptor} is an interceptor that should be at the end of
33	* the {@link WorkflowInboundCallsInterceptor} interceptors chain and which encapsulates calls into
34	* Temporal internals while providing a WorkflowInboundCallsInterceptor interface for chaining on
35	* top of it.
36	*/
37	public abstract class BaseRootWorkflowInboundCallsInterceptor
38	implements WorkflowInboundCallsInterceptor {
39	protected final SyncWorkflowContext workflowContext;
40
41	public BaseRootWorkflowInboundCallsInterceptor(SyncWorkflowContext workflowContext) {	1✔
42	this.workflowContext = workflowContext;	1✔
43	}	1✔
44
45	@Override
46	public void init(WorkflowOutboundCallsInterceptor outboundCalls) {
47	workflowContext.initHeadOutboundCallsInterceptor(outboundCalls);	1✔
48	}	1✔
49
50	@Override
51	public void handleSignal(SignalInput input) {
52	workflowContext.handleInterceptedSignal(input);	1✔
53	}	1✔
54
55	@Override
56	public QueryOutput handleQuery(QueryInput input) {
57	return workflowContext.handleInterceptedQuery(input);	1✔
58	}
59
60	@Override
61	public void validateUpdate(UpdateInput input) {
62	workflowContext.handleInterceptedValidateUpdate(input);	×
63	}	×
64
65	@Override
66	public UpdateOutput executeUpdate(UpdateInput input) {
67	return workflowContext.handleInterceptedExecuteUpdate(input);	×
68	}
69
70	@Nonnull
71	@Override
72	public Object newWorkflowMethodThread(Runnable runnable, String name) {
73	return workflowContext.newWorkflowMethodThreadIntercepted(runnable, name);	1✔
74	}
75
76	@Nonnull
77	@Override
78	public Object newCallbackThread(Runnable runnable, String name) {
79	return workflowContext.newWorkflowCallbackThreadIntercepted(runnable, name);	1✔
80	}
81	}

temporalio / sdk-java / #169

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous