joe/OptionRecorderSchwab
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change the access token to be cached

Browse Source
This commit is contained in:
Joe Tretter
2024-09-03 10:32:56 -05:00
parent 1b94d1d8dc
commit bd682f670f
15 changed files with 29 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
autoTradeQQQLongCall.sh
View File

@@ -4,9 +4,7 @@ IFS=$'\0'
. helpers.sh
./getNewAccessToken.sh
daysOutMin=90
daysOutMin=87
daysOutMax=91
deltaMin=0.35
deltaMax=0.40
@@ -88,7 +86,7 @@ fi
curl -s -X POST \
"https://api.schwabapi.com/trader/v1/accounts/$(./getAccountNumbers.sh IRA)/orders" \
-H "Authorization: Bearer $(<access_token.dat)" \
-H "Authorization: Bearer $(./getNewAccessToken.sh)" \
-H 'accept: */*' \
-H 'Content-Type: application/json' \
-d "${orderJson}"

4
autoTradeSPXPutCreditSpread.sh
View File

@@ -4,8 +4,6 @@ set -e
IFS=$'\0'
myPID=$$
. helpers.sh
./getNewAccessToken.sh
marketOpen=$([[ $(./getMarketHours.sh | jq '.option[].isOpen' | grep true | wc -l) -ne 0 ]] && echo true || echo false)
if [[ ${marketOpen} == false ]]; then
@@ -90,7 +88,7 @@ fi
curl -s -X POST \
"https://api.schwabapi.com/trader/v1/accounts/$(./getAccountNumbers.sh Regular)/orders" \
-H "Authorization: Bearer $(<access_token.dat)" \
-H "Authorization: Bearer $(./getNewAccessToken.sh)" \
-H 'accept: */*' \
-H 'Content-Type: application/json' \
-d "${orderJson}"

4
autoTradeSPX_IB_0DTE_25pctProfitTaker.sh
View File

@@ -4,8 +4,6 @@ set -e
IFS=$'\0'
myPID=$$
. helpers.sh
./getNewAccessToken.sh
marketOpen=$([[ $(./getMarketHours.sh | jq '.option[].isOpen' | grep true | wc -l) -ne 0 ]] && echo true || echo false)
if [[ ${marketOpen} == false ]]; then
@@ -178,7 +176,7 @@ fi
curl -s -X POST \
"https://api.schwabapi.com/trader/v1/accounts/$(./getAccountNumbers.sh Regular)/orders" \
-H "Authorization: Bearer $(<access_token.dat)" \
-H "Authorization: Bearer $(./getNewAccessToken.sh)" \
-H 'accept: */*' \
-H 'Content-Type: application/json' \
-d "${orderJson}"

4
autoTradeSPX_IB_1DTE.sh
View File

@@ -5,8 +5,6 @@ IFS=$'\0'
myPID=$$
. helpers.sh
./getNewAccessToken.sh
marketOpen=$([[ $(./getMarketHours.sh | jq '.option[].isOpen' | grep true | wc -l) -ne 0 ]] && echo true || echo false)
if [[ ${marketOpen} == false ]]; then
throw "The market is closed, exiting." info 2
@@ -134,7 +132,7 @@ fi
curl -s -X POST \
"https://api.schwabapi.com/trader/v1/accounts/$(./getAccountNumbers.sh Regular)/orders" \
-H "Authorization: Bearer $(<access_token.dat)" \
-H "Authorization: Bearer $(./getNewAccessToken.sh)" \
-H 'accept: */*' \
-H 'Content-Type: application/json' \
-d "${orderJson}"

8
autoTradeSPYLongCall.sh
View File

@@ -3,10 +3,8 @@ set -x
IFS=$'\0'
. helpers.sh
./getNewAccessToken.sh
daysOutMin=90
daysOutMin=87
daysOutMax=95
deltaMin=0.35
deltaMax=0.40
@@ -91,9 +89,9 @@ if [[ "${noconfirm}" != "true" ]]; then
read
fi
echo curl -s -X POST \
curl -s -X POST \
"https://api.schwabapi.com/trader/v1/accounts/$(./getAccountNumbers.sh Roth)/orders" \
-H "Authorization: Bearer $(<access_token.dat)" \
-H "Authorization: Bearer $(./getNewAccessToken.sh)" \
-H 'accept: */*' \
-H 'Content-Type: application/json' \
-d "${orderJson}"

2
getAccountNumbers.sh
View File

@@ -4,7 +4,7 @@ mkdir -p temp
tempFile=temp/accountNumbers.tmp.$$.json
tempFlatFile=temp/accountNumbers.flat.$$.tsv
curl -s -X GET "https://api.schwabapi.com/trader/v1/accounts/accountNumbers" -H "Authorization: Bearer $(<access_token.dat)" > ${tempFile}
curl -s -X GET "https://api.schwabapi.com/trader/v1/accounts/accountNumbers" -H "Authorization: Bearer $(./getNewAccessToken.sh)" > ${tempFile}
(jq -r '.[] | [.accountNumber, .hashValue ] | @tsv' < ${tempFile} | while read accNo accHash; do
read accInfo <<< $(grep ${accNo} accountNumberNameMapping.dat; echo ${accNo})
echo ${accInfo} ${accHash}

2
getMarketHours.sh
View File

@@ -40,7 +40,7 @@ done
log "Querying for markets: _${markets}_ query string: _${queryString}_" debug
curl -s -X GET "https://api.schwabapi.com/marketdata/v1/markets${queryString}" \
-H "Authorization: Bearer $(<access_token.dat)" > ${cacheFileName}
-H "Authorization: Bearer $(./getNewAccessToken.sh)" > ${cacheFileName}
marketsCheck=$(jq -e -r '.. | .isOpen?' ${cacheFileName} | grep -v null | wc -l)

22
getNewAccessToken.sh
View File

@@ -2,17 +2,21 @@
#set -x
mkdir -p temp
ageInSec=$(($(date +%s) - $(date +%s -r "access_token.dat")))
curl -s -X POST https://api.schwabapi.com/v1/oauth/token \
-H "Authorization: Basic $(<appCredentials.dat)" \
-H 'Content-Type: application/x-www-form-urlencoded' \
-d "grant_type=refresh_token&refresh_token=$(<refresh_token.dat)" > temp/accessTokenReqResp.$$.json
jq -e -r .access_token temp/accessTokenReqResp.$$.json > access_token.dat
if [[ $? -ne 0 ]]; then
curl -d "" -X POST "https://deadswitch.kawomi.com/api/v1?topic=trade.schwab.error.getNewAccessToken&secs=1&email=joe@kawomi.com"
throw "ERROR: GETTING THE ACCESS TOKEN FAILED! $(<temp/accessTokenReqResp.$$.json)" err
#Cache the last token for 10 min.
if [[ ${ageInSec} -gt 600 ]]; then
curl -s -X POST https://api.schwabapi.com/v1/oauth/token \
-H "Authorization: Basic $(<appCredentials.dat)" \
-H 'Content-Type: application/x-www-form-urlencoded' \
-d "grant_type=refresh_token&refresh_token=$(<refresh_token.dat)" > temp/accessTokenReqResp.$$.json
jq -e -r .access_token temp/accessTokenReqResp.$$.json > access_token.dat
if [[ $? -ne 0 ]]; then
curl -d "" -X POST "https://deadswitch.kawomi.com/api/v1?topic=trade.schwab.error.getNewAccessToken&secs=1&email=joe@kawomi.com"
throw "ERROR: GETTING THE ACCESS TOKEN FAILED! $(<temp/accessTokenReqResp.$$.json)" err
fi
fi
#echo Access Token: $(<access_token.dat)
echo -n -e "$(<access_token.dat)"
## I found the refresh token to be empty after the network is unreachable, therefore I don't handle the refresh token here...
## I have not seen it change, but let's see if they give us a new one before expiry...

2
getOptionChain.sh
View File

@@ -25,7 +25,7 @@ done
log "Querying for Symbol: _${symbol}_ query string: _${queryString}_" debug
curl -s -X GET "https://api.schwabapi.com/marketdata/v1/chains${queryString}" \
-H "Authorization: Bearer $(<access_token.dat)" > temp/optionChain.${symbol}.tmp.$$.json
-H "Authorization: Bearer $(./getNewAccessToken.sh)" > temp/optionChain.${symbol}.tmp.$$.json
jqQuery=".symbol"
symbolCheck=$(jq -r ${jqQuery} < temp/optionChain.${symbol}.tmp.$$.json)

4
getOrders.sh
View File

@@ -18,7 +18,5 @@ done
echo $fromEnteredTime
./getNewAccessToken.sh
curl -s -X GET "https://api.schwabapi.com/trader/v1/orders?fromEnteredTime=${fromEnteredTime}&toEnteredTime=${toEnteredTime}" -H "Authorization: Bearer $(<access_token.dat)" > ${tempFile}
curl -s -X GET "https://api.schwabapi.com/trader/v1/orders?fromEnteredTime=${fromEnteredTime}&toEnteredTime=${toEnteredTime}" -H "Authorization: Bearer $(./getNewAccessToken.sh)" > ${tempFile}
jq -r '.[] | [.orderId | tostring][0] + "," + .status + "," + .orderLegCollection[].instrument.symbol' < ${tempFile}

4
getPositions.sh
View File

@@ -2,9 +2,7 @@
#set -x
mkdir -p temp
./getNewAccessToken.sh
tempFile=temp/accountPositions.tmp.$$.json
curl -s -X GET "https://api.schwabapi.com/trader/v1/accounts/?fields=positions" -H "Authorization: Bearer $(<access_token.dat)" > ${tempFile}
curl -s -X GET "https://api.schwabapi.com/trader/v1/accounts/?fields=positions" -H "Authorization: Bearer $(./getNewAccessToken.sh)" > ${tempFile}
jq -e '{ accountNumber:.[].securitiesAccount.accountNumber, positions:.[].securitiesAccount.positions}' < ${tempFile}

1
recordAllSymbolsSingleRun.sh
View File

@@ -5,7 +5,6 @@
log "Started"
./getNewAccessToken.sh
if [[ $? -ne 0 ]]; then
throw "Child process to get access token reported error. Exiting." err 1
fi

2
recordOptionChainSingleSymbolSingleRun.sh
View File

@@ -27,7 +27,7 @@ done
log "Querying for Symbol: _${symbol}_ query string: _${queryString}_" debug
curl -s -X GET "https://api.schwabapi.com/marketdata/v1/chains${queryString}" \
-H "Authorization: Bearer $(<access_token.dat)" > temp/optionChain.${symbol}.tmp.$$.json
-H "Authorization: Bearer $(./getNewAccessToken.sh)" > temp/optionChain.${symbol}.tmp.$$.json
jqQuery=".symbol"
symbolCheck=$(jq -r ${jqQuery} < temp/optionChain.${symbol}.tmp.$$.json)

2
recordOptionChainSingleSymbolSpecialRun.sh
View File

@@ -24,7 +24,7 @@ for range in ITM OTM NTM; do
log "Querying for Symbol: _${symbol}_ query string: _${queryString}&range=${range}_" debug
curl -s -X GET "https://api.schwabapi.com/marketdata/v1/chains${queryString}&range=${range}" \
-H "Authorization: Bearer $(<access_token.dat)" > temp/optionChain.${symbol}.${range}.tmp.$$.json
-H "Authorization: Bearer $(./getNewAccessToken.sh)" > temp/optionChain.${symbol}.${range}.tmp.$$.json
jqQuery=".symbol"
symbolCheck=$(jq -r ${jqQuery} < temp/optionChain.${symbol}.${range}.tmp.$$.json)

2
recordQuoteSingleSymbolSingleRun.sh
View File

@@ -8,7 +8,7 @@ mkdir -p "${outDir}"
mkdir -p temp
curl -s -X GET "https://api.schwabapi.com/marketdata/v1/${symbol}/quotes?fields=quote%2Creference" \
-H "Authorization: Bearer $(<access_token.dat)" > temp/quote.${symbol}.tmp.$$.json
-H "Authorization: Bearer $(./getNewAccessToken.sh)" > temp/quote.${symbol}.tmp.$$.json
jqQuery=".\"${symbol}\".symbol"
symbolCheck=$(jq -r ${jqQuery} < temp/quote.${symbol}.tmp.$$.json)