blob: 0e06d5a5cdf6048c122fe004e71f976f34d822eb (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
#!/bin/bash
# lji: this is basically what Dom has in his regtest. re-do it in bash instead of ksh
HOSTPORT="127.0.0.1:3904"
ANONTOPIC="anon-topic-$RANDOM"
APITOPIC="api-topic-$RANDOM"
APIKEYFILE="/tmp/key"
echo "blah" > /tmp/sample.txt
if [ ! -e /usr/bin/jq ]; then
apt-get update && apt-get -y install jq
fi
# list topics
curl http://${HOSTPORT}/topics
# publish to an anonymous topic (first publish creats the topic)
curl -H "Content-Type:text/plain" -X POST -d @/tmp/sample.txt http://${HOSTPORT}/events/$ANONTOPIC
# subscribe to an anonymous topic
curl -H "Content-Type:text/plain" -X GET http://${HOSTPORT}/events/$ANONTOPIC/group1/C1?timeout=5000 &
curl -H "Content-Type:text/plain" -X POST -d @/tmp/sample.txt http://${HOSTPORT}/events/$ANONTOPIC
# create api key
echo '{"email":"no email","description":"API key and secret both in reponse"}' > /tmp/input.txt
curl -s -o ${APIKEYFILE} -H "Content-Type:application/json" -X POST -d @/tmp/input.txt http://${HOSTPORT}/apiKeys/create
UEBAPIKEYSECRET=`cat ${APIKEYFILE} |jq -r ".secret"`
UEBAPIKEYKEY=`cat ${APIKEYFILE} |jq -r ".key"`
# create an api key secured topic
# pay attendtion to replication count
echo '{"topicName":"'${APITOPIC}'","topicDescription":"This is an API key securedTopic","partitionCount":"1","replicationCount":"1","transactionEnabled":"true"}' > /tmp/topicname.txt
time=`date --iso-8601=seconds`
signature=$(echo -n "$time" | openssl sha1 -hmac $UEBAPIKEYSECRET -binary | openssl base64)
xAuth=$UEBAPIKEYKEY:$signature
xDate="$time"
curl -i -H "Content-Type: application/json" -H "X-CambriaAuth:$xAuth" -H "X-CambriaDate:$xDate" -X POST -d @/tmp/topicname.txt http://${HOSTPORT}/topics/create
# first subscribe and run it in bg. then publish.
time=`date --iso-8601=seconds`
signature=$(echo -n "$time" | openssl sha1 -hmac $UEBAPIKEYSECRET -binary | openssl base64)
xAuth=$UEBAPIKEYKEY:$signature
xDate="$time"
curl -H "X-CambriaAuth:$xAuth" -H "X-CambriaDate:$xDate" -X GET http://${HOSTPORT}/events/${APITOPIC}/g0/u1 &
curl -H "Content-Type:text/plain" -H "X-CambriaAuth:$xAuth" -H "X-CambriaDate:$xDate" -X POST -d @/tmp/sample.txt http://${HOSTPORT}/events/${APITOPIC}
|
