org.xdi.oxd.server.Processor クラス

org.xdi.oxd.server.Processor 連携図

公開メンバ関数
	Processor (ValidationService validationService)
String	process (String p_command)
CommandResponse	process (Command command)

非公開変数類
final ValidationService	validationService

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(Processor.class)

詳解

oxD operation processor.

著者

Yuriy Zabrovarnyy

構築子と解体子

Processor()

org.xdi.oxd.server.Processor.Processor ( ValidationService  validationService )

inline

                                                          {
        this.validationService = validationService;
    }

関数詳解

process() [1/2]

String org.xdi.oxd.server.Processor.process ( String  p_command )

inline

Processed command.

引数

p_command

command as string

戻り値

response as string

                                            {
        LOG.trace("Command: {}", p_command);
        try {
            if (StringUtils.isNotBlank(p_command)) {
                final Command command = CoreUtils.createJsonMapper().readValue(p_command, Command.class);
                final CommandResponse response = process(command);
                if (response != null) {
                    final String json = CoreUtils.asJson(response);
                    LOG.trace("Send back response: {}", json);
                    return json;
                } else {
                    LOG.error("There is no response produced by Processor.");
                    return null;
                }
            }
        } catch (IOException e) {
            LOG.error(e.getMessage(), e);
        }
        LOG.trace("No command or it's corrupted. Stop handling commands for this client.");
        return CommandResponse.INTERNAL_ERROR_RESPONSE_AS_STRING;
    }

process() [2/2]

CommandResponse org.xdi.oxd.server.Processor.process ( Command  command )

inline

                                                    {
        if (command != null) {
            try {
                final IOperation<IParams> operation = (IOperation<IParams>) OperationFactory.create(command, ServerLauncher.getInjector());
                if (operation != null) {
                    IParams iParams = Convertor.asParams(operation.getParameterClass(), command);
                    Pair<Rp, Boolean> rpWithIsClientLocalPair = validationService.validate(iParams);

                    CommandResponse operationResponse = operation.execute(iParams);
                    if (operationResponse != null) {
                        if (operationResponse.getStatus() == ResponseStatus.OK && rpWithIsClientLocalPair != null) { // report usage only of operation is ok
                            ServerLauncher.getInjector().getInstance(LicenseService.class).notifyClientUsed(rpWithIsClientLocalPair.getFirst(), rpWithIsClientLocalPair.getSecond());
                        }
                        return operationResponse;
                    } else {
                        LOG.error("No response from operation. Command: " + command);
                    }
                } else {
                    LOG.error("Operation is not supported!");
                    return CommandResponse.OPERATION_IS_NOT_SUPPORTED;
                }
            } catch (ErrorResponseException e) {
                LOG.error(e.getLocalizedMessage(), e);
                return CommandResponse.createErrorResponse(e.getErrorResponseCode());
            } catch (Throwable e) {
                LOG.error(e.getMessage(), e);
            }
        }
        return CommandResponse.INTERNAL_ERROR_RESPONSE;
    }

メンバ詳解

LOG

final Logger org.xdi.oxd.server.Processor.LOG = LoggerFactory.getLogger(Processor.class)

staticprivate

Logger

validationService

final ValidationService org.xdi.oxd.server.Processor.validationService

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/Processor.java