apigee · srinandan · Mar 19, 2021
diff --git a/perf-proxies/README.md b/perf-proxies/README.md
@@ -0,0 +1,28 @@
+# API proxy for Performance Benchmark
+
+This directory contains the API proxy and Sharedflow used to performance test
+Apigee X and Apigee hybrid instances.
+
+## About this sample proxy
+
+This API proxy uses the following policies
+
+* Access Control
+* Access Entity
+* Validate OAuth
+* Validate API Key
+* JavaScript
+* Assign Message
+* Quota
+* XMLThreat Protection
+* GenerateAccessToken
+* Python Callout
+* XSLT
+* XMLToJSON
+* Raise-Fault
+* FlowCallout
+* ServiceCallout
+* GenerateJWT
+* VerifyJWT
+
+The API Proxy is available on the basePath `/hybridperf`
diff --git a/perf-proxies/proxy/apiproxy/hybrid_perf.xml b/perf-proxies/proxy/apiproxy/hybrid_perf.xml
@@ -0,0 +1,69 @@
+<APIProxy revision="25" name="hybrid_perf">
+    <DisplayName>hybrid_perf</DisplayName>
+    <Description>Performance Test App</Description>
+    <CreatedAt>1596042552317</CreatedAt>
+    <LastModifiedAt>1596042660545</LastModifiedAt>
+    <BasePaths>/hybridperf</BasePaths>
+    <Policies>
+        <Policy>ValidMessage</Policy>
+        <Policy>LimitBySlowQuota</Policy>
+        <Policy>RejectURI</Policy>
+        <Policy>LimitByIP</Policy>
+        <Policy>SetPayload_AccessEntity_ApiProduct</Policy>
+        <Policy>ValidateOAuth</Policy>
+        <Policy>ValidateKey</Policy>
+        <Policy>getURL</Policy>
+        <Policy>AccessEntity_AppName</Policy>
+        <Policy>SetPayload_AccessEntity_AppID</Policy>
+        <Policy>SetPayload_AccessEntity_AppName</Policy>
+        <Policy>JSHeader</Policy>
+        <Policy>putURL</Policy>
+        <Policy>RemoveQueryParams</Policy>
+        <Policy>LimitByQuota</Policy>
+        <Policy>AccessEntity_Developer</Policy>
+        <Policy>SetCacheHeader</Policy>
+        <Policy>ResponseCache</Policy>
+        <Policy>XMLThreat</Policy>
+        <Policy>GenerateAccessToken</Policy>
+        <Policy>EncodeURI</Policy>
+        <Policy>PYHeader</Policy>
+        <Policy>GenerateRandomNumber</Policy>
+        <Policy>PYParse</Policy>
+        <Policy>AccessEntity_AppID</Policy>
+        <Policy>SetPayload_AccessEntity_Developer</Policy>
+        <Policy>XSLT</Policy>
+        <Policy>AccessEntity_ApiProduct</Policy>
+        <Policy>XMLToJSON</Policy>
+        <Policy>assign-header</Policy>
+        <Policy>Raise-Fault</Policy>
+        <Policy>FlowCallout</Policy>
+        <Policy>ServiceCallout</Policy>
+        <Policy>SC-BuildRequest</Policy>
+        <Policy>ExtractSCResponse</Policy>
+        <Policy>AssignSCResponse</Policy>
+        <Policy>ScJSON</Policy>
+        <Policy>GenerateJWT</Policy>
+        <Policy>VerifyJWT</Policy>
+        <Policy>RF-MissingParam</Policy>
+        <Policy>AM-PrivateKey</Policy>
+        <Policy>AM-Response</Policy>
+        <Policy>AM-JwtAuthorization</Policy>
+        <Policy>add-cors</Policy>
+        <Policy>ResponsePayload</Policy>
+    </Policies>
+    <ProxyEndpoints>
+        <ProxyEndpoint>proxy</ProxyEndpoint>
+    </ProxyEndpoints>
+    <Resources>
+        <Resource>py://pyparse.py</Resource>
+        <Resource>py://encodeuri.py</Resource>
+        <Resource>py://pyheader.py</Resource>
+        <Resource>jsc://RandomNumber.js</Resource>
+        <Resource>xsl://weatherxsl</Resource>
+        <Resource>js://jsheader.js</Resource>
+    </Resources>
+    <TargetServers></TargetServers>
+    <TargetEndpoints>
+        <TargetEndpoint>static</TargetEndpoint>
+    </TargetEndpoints>
+</APIProxy>
diff --git a/perf-proxies/proxy/apiproxy/policies/AM-JwtAuthorization.xml b/perf-proxies/proxy/apiproxy/policies/AM-JwtAuthorization.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<AssignMessage async="false" continueOnError="false" enabled="true" name="AM-JwtAuthorization">
+    <DisplayName>AM-JwtAuthorization</DisplayName>
+    <Properties/>
+    <Add>
+        <Headers/>
+        <Header name="Authorization">Bearer {output-jwt}</Header>
+    </Add>
+    <AssignVariable>
+        <Name>public.publickey</Name>
+        <!-- better to have this stored in the KVM, but this is a demo -->
+        <Value>
+        -----BEGIN PUBLIC KEY-----
+        MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAwQNvdXmQMHaCj+cKOhaB
+        SVGMsgElLuAoU4yiHv/NFepQOKt5m3gcyK3t1sE2nMWebTQH1QLC9fANROeXVpJn
+        05E57LffR3RFp7bFT8dI6OG7xlpypUcw1KEx6D2uTRQ29GStq2/nM+HNu6RtHJi4
+        C+Z3dIUsW7nV0FjVZIsCxA1z/fPFVy8rGERaRR+tWHTm5U2jKXEw3ileUv7LGgWM
+        UMmxuqW2qyrkbVNC+gyI2AKmUV9bo/qLa0BrFxUrK2nRJlxmGnSA09s5CGKix2hP
+        GxBCvO4wHQ1Wt1PZzDO/fKlkxYiCdALLn8VwKS3JqgInnPUDl1tRi6fDEhL3lKFP
+        JwIDAQAB
+        -----END PUBLIC KEY-----
+        </Value>
+    </AssignVariable>
+    <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
+    <AssignTo createNew="false" transport="http" type="request"/>
+</AssignMessage>
diff --git a/perf-proxies/proxy/apiproxy/policies/AM-PrivateKey.xml b/perf-proxies/proxy/apiproxy/policies/AM-PrivateKey.xml
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<AssignMessage async="false" continueOnError="false" enabled="true" name="AM-PrivateKey">
+    <DisplayName>AM-PrivateKey</DisplayName>
+    <Properties/>
+    <AssignVariable>
+        <Name>private.privatekey</Name>
+        <!-- better to have this stored in the KVM, but this is a demo -->
+        <Value>
+-----BEGIN PRIVATE KEY-----
+MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQDBA291eZAwdoKP
+5wo6FoFJUYyyASUu4ChTjKIe/80V6lA4q3mbeBzIre3WwTacxZ5tNAfVAsL18A1E
+55dWkmfTkTnst99HdEWntsVPx0jo4bvGWnKlRzDUoTHoPa5NFDb0ZK2rb+cz4c27
+pG0cmLgL5nd0hSxbudXQWNVkiwLEDXP988VXLysYRFpFH61YdOblTaMpcTDeKV5S
+/ssaBYxQybG6pbarKuRtU0L6DIjYAqZRX1uj+otrQGsXFSsradEmXGYadIDT2zkI
+YqLHaE8bEEK87jAdDVa3U9nMM798qWTFiIJ0AsufxXApLcmqAiec9QOXW1GLp8MS
+EveUoU8nAgMBAAECggEAPOhhnteaqcBsGQ8WihgZ+lISrQVxf2ZbM2pYqqGcTUMg
+x5FNEcOIicdhG3jjS/uMr/dQVWbGsSdseIcAmeAfhYL5nXq0qe7GIFOr1i4UEvFQ
++RoHvaJGhYLMpfX47/fmE59Fsqjgc93Yt1L+35xNz+uNXKa9xcBR+apexJidadIs
+pcXTrmyANwjaKKM6t/HIHK7tiOnX/HSrYinSsDTsLQkxkToQrWxFv8U6DS3sQQGU
+Yjc0gqpgbj0JnlC6ekMYCTk3Loit9MmqkdYidPHCKi3z1sH0+Yo5xQwGbF+CumZk
+m2RDDGGC3/F44kM8QnHT8XJ9O8w16BgHqMVBcUnLGQKBgQDkPLKcupPoS1j9/Hqd
+XFJGmGB+pUBaRRD9+Uz/dR3uN9rfhDY47I+9rjOo0pqiI3ATYFYFGbf4OfrF97+m
+TT1vkg7WxnnfzU7z9MP3aAylINjABpRTqVEWsgRfHy/sT7wSO0l+dZTwSUwM0taq
+OuWKdM9hfKZiOGrTWW4u9Vir7QKBgQDYfd9WiG1g1iP6NxMqNns7GbQctR5L581T
+00xnqZ0IRLYLuvoOtAkSBkAsF3oaT+/z4VVO8PdJpOTYyTM4gUP7uZinwQK7Ge/2
+QaWSsFLABjj4lYaWiDgkjKje+Vd3GvCHQ0T21wV6XwxV4pZe2mUvLsbLAwJBNIpE
+nZXXFgDM4wKBgDHiYleHIBTBgy3gJRyHtSPg4hZMIAia19/qwT2EZ4pNgvUffIps
+ie43SOs5PLr7a9+QSrzKpj8GzRy/zY+Xijn8fmnK75BO21bOxJYqk7jzuOwfhAPV
+GfgP6Iyx0FOiCcUiWCnfoTHzkz+qRWjnfowIg9sW13bYReDzxvVUgpDxAoGAX0nX
++dCGxC69Gy8Oom/kgbjojBI0SZi3yYOhh6ciVTdZIYSk97/KlkJmEIIs3lP8+81c
+rShmz+ViTQESKHbNI4knZf8QYqYh9rQiWpR9d8PFY7T8zlkazQuUcMAy/VvALuku
++67c3GXlmg/nu8xI6SGfok+quGSVz2nFQCyRIZ0CgYBLt/uYBJokcuC5uNsy84uZ
+WqEjrJem/JjPsmlJFOxSfMWPPeXFwno8o4qoFpPyxUN9rPPTC4wIusWDvfXX1eHB
+yc4C9HX8qjg2nn1oVLO7CVEIxmrwUNcoS+wiyYJIhygViege6lshS5DjpQc4UQh+
+SXJJ2CgUNZdFEN8y0L3JXA==
+-----END PRIVATE KEY-----
+        </Value>
+    </AssignVariable>
+</AssignMessage>
diff --git a/perf-proxies/proxy/apiproxy/policies/AM-Response.xml b/perf-proxies/proxy/apiproxy/policies/AM-Response.xml
@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<AssignMessage async="false" continueOnError="false" enabled="true" name="AM-Response">
+    <DisplayName>AM-Response</DisplayName>
+    <Properties/>
+    <!-- <AssignTo createNew='false' transport='http' type='response'></AssignTo> -->
+    <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
+    <Set>
+        <Payload contentType="application/json">{
+  "status" : "ok",
+  "jwt" : "{output-jwt}"
+}</Payload>
+        <StatusCode>200</StatusCode>
+    </Set>
+</AssignMessage>
diff --git a/perf-proxies/proxy/apiproxy/policies/AccessEntity_ApiProduct.xml b/perf-proxies/proxy/apiproxy/policies/AccessEntity_ApiProduct.xml
@@ -0,0 +1,5 @@
+<AccessEntity enabled="true" continueOnError="false" async="false" name="AccessEntity_ApiProduct">
+    <EntityType  value="apiproduct"/>
+    <EntityIdentifier ref="request.queryparam.id" /> 
+</AccessEntity>
+
diff --git a/perf-proxies/proxy/apiproxy/policies/AccessEntity_AppID.xml b/perf-proxies/proxy/apiproxy/policies/AccessEntity_AppID.xml
@@ -0,0 +1,4 @@
+<AccessEntity enabled="true" continueOnError="false" async="false" name="AccessEntity_AppID">
+    <EntityType  value="app"/>
+    <EntityIdentifier ref="request.queryparam.id" type="appid"/> 
+</AccessEntity>
diff --git a/perf-proxies/proxy/apiproxy/policies/AccessEntity_AppName.xml b/perf-proxies/proxy/apiproxy/policies/AccessEntity_AppName.xml
@@ -0,0 +1,4 @@
+<AccessEntity enabled="true" continueOnError="false" async="false" name="AccessEntity_AppName">
+    <EntityType  value="app"/>
+    <EntityIdentifier ref="request.queryparam.id" type="appname"/> 
+</AccessEntity>
diff --git a/perf-proxies/proxy/apiproxy/policies/AccessEntity_Developer.xml b/perf-proxies/proxy/apiproxy/policies/AccessEntity_Developer.xml
@@ -0,0 +1,5 @@
+<AccessEntity enabled="true" continueOnError="false" async="false" name="AccessEntity_Developer">
+    <EntityType  value="developer"/>
+    <EntityIdentifier ref="request.queryparam.id" /> 
+</AccessEntity>
+
diff --git a/perf-proxies/proxy/apiproxy/policies/AssignSCResponse.xml b/perf-proxies/proxy/apiproxy/policies/AssignSCResponse.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<AssignMessage async="false" continueOnError="false" enabled="true" name="AssignSCResponse">
+    <DisplayName>AssignSCResponse</DisplayName>
+    <Properties/>
+    <Set>
+        <Payload contentType="application/json" variablePrefix="@" variableSuffix="#">
+        @scjsonres#
+    </Payload>
+    </Set>
+    <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
+    <AssignTo createNew="false" transport="http" type="response"/>
+</AssignMessage>
diff --git a/perf-proxies/proxy/apiproxy/policies/EncodeURI.xml b/perf-proxies/proxy/apiproxy/policies/EncodeURI.xml
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Script enabled="true" continueOnError="false" async="false" name="EncodeURI">
+    <DisplayName>EncodeURI</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <ResourceURL>py://encodeuri.py</ResourceURL>
+</Script>
diff --git a/perf-proxies/proxy/apiproxy/policies/ExtractSCResponse.xml b/perf-proxies/proxy/apiproxy/policies/ExtractSCResponse.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<ExtractVariables async="false" continueOnError="true" enabled="true" name="ExtractSCResponse">
+    <DisplayName>ExtractSCResponse</DisplayName>
+    <Properties/>
+    <Source clearPayload="false">SCResponse</Source>
+    <JSONPayload>
+        <Variable name="scjsonres" type="nodeset">
+            <JSONPath>$.</JSONPath>
+        </Variable>
+    </JSONPayload>
+</ExtractVariables>
diff --git a/perf-proxies/proxy/apiproxy/policies/FlowCallout.xml b/perf-proxies/proxy/apiproxy/policies/FlowCallout.xml
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<FlowCallout async="false" continueOnError="false" enabled="true" name="FlowCallout">
+    <DisplayName>FlowCallout</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <SharedFlowBundle>hybridperf-sfassignmessage</SharedFlowBundle>
+</FlowCallout>
diff --git a/perf-proxies/proxy/apiproxy/policies/GenerateAccessToken.xml b/perf-proxies/proxy/apiproxy/policies/GenerateAccessToken.xml
@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<OAuthV2 enabled="true" continueOnError="false" async="false" name="GenerateAccessToken">
+    <DisplayName>GenerateAccessToken</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <Attributes/>
+    <ExpiresIn>86400000</ExpiresIn>
+    <ExternalAuthorization>false</ExternalAuthorization>
+    <GrantType>request.queryparam.grant_type</GrantType>
+    <Operation>GenerateAccessToken</Operation>
+    <GenerateResponse enabled="true">
+        <Format>FORM_PARAM</Format>
+    </GenerateResponse>
+    <SupportedGrantTypes>
+        <GrantType>client_credentials</GrantType>
+    </SupportedGrantTypes>
+    <Tokens/>
+</OAuthV2>
diff --git a/perf-proxies/proxy/apiproxy/policies/GenerateJWT.xml b/perf-proxies/proxy/apiproxy/policies/GenerateJWT.xml
@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<GenerateJWT async="false" continueOnError="false" enabled="true" name="GenerateJWT">
+    <DisplayName>GenerateJWT</DisplayName>
+    <Algorithm>RS256</Algorithm>
+    <PrivateKey>
+        <Value ref="private.privatekey"/>
+        <Id>optional-unique-identifier-for-privatekey-here</Id>
+    </PrivateKey>
+    <!-- including the optional Id element tells Apigee to generate a unique identifier for the JWT -->
+    <Id/>
+    <Subject ref="request.queryparam.subject"/>
+    <!-- issuer can be specified by ref= as well -->
+    <Issuer>urn://apigee-edge-JWT-policy-demonstration</Issuer>
+    <Audience>urn://Apigee</Audience>
+    <!-- specifying expiry is recommended but optional -->
+    <ExpiresIn>60m</ExpiresIn>
+    <OutputVariable>output-jwt</OutputVariable>
+</GenerateJWT>
diff --git a/perf-proxies/proxy/apiproxy/policies/GenerateRandomNumber.xml b/perf-proxies/proxy/apiproxy/policies/GenerateRandomNumber.xml
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Javascript async="false" continueOnError="false" enabled="true" timeLimit="200" name="GenerateRandomNumber">
+    <DisplayName>GenerateRandomNumber</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <ResourceURL>jsc://RandomNumber.js</ResourceURL>
+</Javascript>
diff --git a/perf-proxies/proxy/apiproxy/policies/JSHeader.xml b/perf-proxies/proxy/apiproxy/policies/JSHeader.xml
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Script enabled="true" continueOnError="false" async="false" name="JSHeader">
+    <DisplayName>JSHeader</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <ResourceURL>js://jsheader.js</ResourceURL>
+</Script>
diff --git a/perf-proxies/proxy/apiproxy/policies/LimitByIP.xml b/perf-proxies/proxy/apiproxy/policies/LimitByIP.xml
@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<SpikeArrest enabled="true" continueOnError="false" async="false" name="LimitByIP">
+    <DisplayName>LimitByIP</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <Identifier ref="client.ip"/>
+    <Rate>50000ps</Rate>
+</SpikeArrest>
diff --git a/perf-proxies/proxy/apiproxy/policies/LimitByQuota.xml b/perf-proxies/proxy/apiproxy/policies/LimitByQuota.xml
@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Quota enabled="true" continueOnError="false" async="false" name="LimitByQuota">
+    <DisplayName>LimitByQuota</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <Identifier ref="request.queryparam.quota"/>
+    <Allow count="5000000"/>
+    <Interval>1</Interval>
+    <Distributed>true</Distributed>
+    <PreciseAtSecondsLevel>false</PreciseAtSecondsLevel>
+    <Synchronous>false</Synchronous>
+    <TimeUnit>minute</TimeUnit>
+</Quota>
diff --git a/perf-proxies/proxy/apiproxy/policies/LimitBySlowQuota.xml b/perf-proxies/proxy/apiproxy/policies/LimitBySlowQuota.xml
@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Quota enabled="true" continueOnError="false" async="false" name="LimitBySlowQuota">
+    <DisplayName>LimitBySlowQuota</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <Identifier ref="request.queryparam.quota"/>
+    <Allow count="5000000"/>
+    <Interval>1</Interval>
+    <Distributed>true</Distributed>
+    <PreciseAtSecondsLevel>false</PreciseAtSecondsLevel>
+    <Synchronous>true</Synchronous>
+    <TimeUnit>minute</TimeUnit>
+</Quota>
diff --git a/perf-proxies/proxy/apiproxy/policies/PYHeader.xml b/perf-proxies/proxy/apiproxy/policies/PYHeader.xml
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Script enabled="true" continueOnError="false" async="false" name="PYHeader">
+    <DisplayName>PYHeader</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <ResourceURL>py://pyheader.py</ResourceURL>
+</Script>
diff --git a/perf-proxies/proxy/apiproxy/policies/PYParse.xml b/perf-proxies/proxy/apiproxy/policies/PYParse.xml
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<Script enabled="true" continueOnError="false" async="false" name="PYParse">
+    <DisplayName>PYParse</DisplayName>
+    <FaultRules/>
+    <Properties/>
+    <ResourceURL>py://pyparse.py</ResourceURL>
+</Script>
diff --git a/perf-proxies/proxy/apiproxy/policies/RF-MissingParam.xml b/perf-proxies/proxy/apiproxy/policies/RF-MissingParam.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<RaiseFault name="RF-MissingParam">
+    <FaultResponse>
+        <Set>
+            <Headers/>
+            <Payload contentType="text/plain">Missing form Parameter</Payload>
+            <StatusCode>400</StatusCode>
+            <ReasonPhrase>Bad Request</ReasonPhrase>
+        </Set>
+    </FaultResponse>
+    <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
+</RaiseFault>
diff --git a/perf-proxies/proxy/apiproxy/policies/Raise-Fault.xml b/perf-proxies/proxy/apiproxy/policies/Raise-Fault.xml
@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<RaiseFault async="false" continueOnError="false" enabled="true" name="Raise-Fault">
+    <DisplayName>Raise-Fault</DisplayName>
+    <Properties/>
+    <FaultResponse>
+        <Set>
+            <Headers/>
+            <Payload contentType="text/plain">
+                Good job Google
+            </Payload>
+            <StatusCode>200</StatusCode>
+            <ReasonPhrase>Ok</ReasonPhrase>
+        </Set>
+    </FaultResponse>
+    <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
+</RaiseFault>