73   N N         N  N  N  N      N  N  N ! N" #$ % & ' ( #) #* + , - . N/ 0 1 23 4 5 6 N7 89  :; < = > ? 4@ A B 4CD 4E F GH  I J K LM NN O NPQR IS T IUVWX YZ[ R\ E] ^ N_ N` a Rb Ec Nd Ne Rf Rg Nh Rij a ak Rl mn  opq  r  s 2t 2u vw xy} R R~ R   a   a k          ]  N  2loggerLorg/slf4j/Logger;OK_STATE_RETURNLjava/lang/String; ConstantValue redisModuleLpl/ttpsc/redis/RedisModule;farGateTaskManager%Lpl/ttpsc/fargate/FargateTaskManager;$THING_CONNECTOR_INSTANCE_REDIS_FIELDTHING_MODEL_REDIS_FIELDPROPERTY_TYPE_REDIS_FIELD INSTANCE_PREFIX_NAME_REDIS_FIELDFARGATE_TASK_DEFINITIONFARGATE_CLUSTERFARGATE_CONTAINER_NAMEFARGATE_ENVIRONMENT_NAME ENVIRONMENT()VCodeLineNumberTableLocalVariableTablethis%Lpl/ttpsc/ThingworxDataFetcherLambda; handleRequestR(Ljava/util/Map;Lcom/amazonaws/services/lambda/runtime/Context;)Ljava/lang/String;thing.Lpl/ttpsc/thingworx/thingData/thing/ThingData;appConfigModule$Lpl/ttpsc/appconfig/AppConfigModule;thingworxClient6Lpl/ttpsc/thingworx/connection/config/ThingworxClient;%connectorApplicationInstancesListNamethingworxClientApplicationListLjava/util/List;thingworxThingFetcher4Lpl/ttpsc/thingworx/thingData/ThingworxThingFetcher;numberOfThingsPerInstanceJeLjava/lang/Exception;$exLjava/lang/Throwable;eventLjava/util/Map;context/Lcom/amazonaws/services/lambda/runtime/Context;LocalVariableTypeTable=Ljava/util/List;5Ljava/util/Map; StackMapTable Signaturex(Ljava/util/Map;Lcom/amazonaws/services/lambda/runtime/Context;)Ljava/lang/String;handleOneThingT(Ljava/lang/String;Ljava/util/List;JLpl/ttpsc/thingworx/thingData/thing/ThingData;)VthingworxClientApplication+Lpl/ttpsc/redis/ThingworxClientApplication;twxClientInstanceIndexIi isThingNameAssignedToTwxInstanceZ(Ljava/lang/String;Ljava/util/List;JLpl/ttpsc/thingworx/thingData/thing/ThingData;)V3getTwxClientInstanceIndexAndHandleRedisInstanceListU(Ljava/lang/String;Ljava/util/List;JLpl/ttpsc/thingworx/thingData/thing/ThingData;I)I&canAddThingToExistingTwxClientInstance(Ljava/lang/String;Ljava/util/List;JLpl/ttpsc/thingworx/thingData/thing/ThingData;I)I3updateThingworxClientApplicationInstanceListInRedis7(Ljava/lang/String;Ljava/util/List;Ljava/lang/String;)VinstanceJsonFormat4Lcom/fasterxml/jackson/core/JsonProcessingException;instanceListNamethingworxClientApplicationsenvironmentAppConfigd(Ljava/lang/String;Ljava/util/List;Ljava/lang/String;)VlaunchFargateTask'(Ljava/lang/String;Ljava/lang/String;)V instanceName-createNewInstanceOfThingworxClientApplication@(Ljava/lang/String;I)Lpl/ttpsc/redis/ThingworxClientApplication;numberOfExistingInstancessetThingDataInRedisW(Ljava/lang/String;Ljava/lang/String;Lcom/fasterxml/jackson/databind/node/ObjectNode;)V jsonStringmapper-Lcom/fasterxml/jackson/databind/ObjectMapper;node0Lcom/fasterxml/jackson/databind/node/ObjectNode; redisValue thingName thingInstance modelData'checkIfThingNameIsNotSameAsInstanceList'(Ljava/lang/String;Ljava/lang/String;)ZcreateJsonModelForPropertiesB(Ljava/util/List;)Lcom/fasterxml/jackson/databind/node/ObjectNode; thingProperty2Lpl/ttpsc/thingworx/thingData/thing/ThingProperty; propertiesmodelPropertiesDLjava/util/List;v(Ljava/util/List;)Lcom/fasterxml/jackson/databind/node/ObjectNode;U(Ljava/lang/Object;Lcom/amazonaws/services/lambda/runtime/Context;)Ljava/lang/Object;Ljava/lang/Object;Lcom/amazonaws/services/lambda/runtime/RequestHandler;Ljava/lang/String;>; SourceFileThingworxDataFetcherLambda.java   Lambda started         tThe following keys will be inserted in to redis received from app config: {} with prefix: {}, {} with type field: {}java/lang/Object                         /Redis list {} is either restarted or it's empty 2pl/ttpsc/thingworx/thingData/ThingworxThingFetcher        'Number of things to update in redis: {}       ,pl/ttpsc/thingworx/thingData/thing/ThingData  java/lang/ExceptionCouldn't connect to thingworx   #pl/ttpsc/ThingworxDataFetcherLambda200java/lang/Throwable )pl/ttpsc/redis/ThingworxClientApplication         +com/fasterxml/jackson/databind/ObjectMapper   4Updating Thingworx client application with value: {} 2com/fasterxml/jackson/core/JsonProcessingException>Couldn't parse object ThingworxClientApplication into json: {}        BootstrapMethods       =Adding dead Thingworx client application instance to redis {}    8Couldn't create json for Thing: {}, to send to redis: {}  !Data send to redis about Things: key: {}, value: {} YThing name: {} of Thing is same as name of instance list: {}, couldn't add Thing to redis   !0pl/ttpsc/thingworx/thingData/thing/ThingProperty "  java/util/Map #  $% &' (4com/amazonaws/services/lambda/runtime/RequestHandler-com/amazonaws/services/lambda/runtime/Context"pl/ttpsc/appconfig/AppConfigModule4pl/ttpsc/thingworx/connection/config/ThingworxClientjava/lang/Stringjava/util/Listjava/util/Iterator.com/fasterxml/jackson/databind/node/ObjectNodepl/ttpsc/redis/RedisModule getInstance()Lpl/ttpsc/redis/RedisModule;org/slf4j/Logger isInfoEnabled()Zjava/lang/BooleanvalueOf(Z)Ljava/lang/Boolean;info'(Ljava/lang/String;Ljava/lang/Object;)V&()Lpl/ttpsc/appconfig/AppConfigModule;getInstanceIndicator()Ljava/lang/String;getThingModelIndicator#getModelParametersDataTypeIndicator)getTwxCloudConnectorAppInstanceNamePrefixisDebugEnableddebug((Ljava/lang/String;[Ljava/lang/Object;)VgetTaskDefinition getClustergetContainerName?@A>B:  C DE: * F*-GH IYJK*LNIY-M: *L ON-IPI N\4$ NIIIP BP/>@B C'D.E5F[HdFiKpLwM~NPQRPTVXZ\]^`adefg"i)j1k6mXozpqrtyzvwyz{;z z ")y  666,B:  C1 DR:  STU 66 *+,!V6*T+W#*T,XRY*Z[\' NE1R,J '9=@CFIN[hk\ '   g 66,B:  C/ DR:  S?! 66 ,*+,?01W,?d6*T+W,XRT]/R >$47;>ADI[er\ $  z,B:CqDR:^*Y-_`aYbc:+defg:ijk:6^ahP-RjhBPB&06DJOR^acz}RDc_ a)+,l)m ]nopNRYq:-r`s-t5+aYbcu:ijkv-3N-4GJh~P+JNRhNP:$*4GJLcf | HLpgaYb:w: ,xW -yWz{:-:|Y+SYSYjS}+~+t:gY+SYSYS:$03hP;3Nah)NNP> $0"35 Z!]#f$o%&'p 05( ]Lo:0+,)Y+SY,SYS.12,3.5 000PaYbM,wN+B:C2D:,w:xW-W-a8"?@ A+B1C?DKENF>1+ PPH C PA4 *+,  0N)  %. ,0-z{|{