My logpush just stopped pushing logs It
My logpush just stopped pushing logs.. It's an http source and it says pushing

184337test body but says it's JSON in the content type
184454184458Bearer part is not caps correctly lol. The whole auth header is just Bearer right now not sure why because my token injection is working...test request? I'd love to just send directly to axiom instead of the workercurl -X POST "https://api.cloudflare.com/client/v4/accounts/$ACCOUNTID/logpush/jobs" \
-H "X-Auth-Key: $APIKEY" \
-H "X-Auth-Email: $EMAIL" \
-H "Content-Type: application/json" \
-d "{
\"name\": \"workers-logpush\",
\"output_options\": {
\"field_names\": [\"ClientIP\", \"EdgeStartTimestamp\", \"RayID\", \"Event\", \"EventTimestampMs\", \"Outcome\", \"Exceptions\", \"Logs\", \"ScriptName\"],
\"sample_rate\": 1.0,
\"timestamp_format\": \"unixnano\",
\"output_type\": \"ndjson\",
\"batch_prefix\": \"[\",
\"batch_suffix\": \"]\",
\"record_prefix\": \"{\",
\"record_suffix\": \"}\",
\"record_delimiter\": \",\"
},
\"filter\": \"{\\\"where\\\":{\\\"key\\\":\\\"ScriptName\\\",\\\"operator\\\":\\\"\!eq\\\",\\\"value\\\":\\\"cloudflareaxioslogpush\\\"}}\",
\"destination_conf\": \"https://$SUBDOMAIN.workers.dev/log?header_Authorization=Bearer%20$TOKEN&header_content-type=application%2Fjson\",
\"dataset\": \"workers_trace_events\",
\"enabled\": true
}"export interface Env {
TOKEN: string
DATASET: string
}
export default {
async fetch(
request: Request,
env: Env,
ctx: ExecutionContext
): Promise<Response> {
if (request.headers.get("content-length") === "4") {
console.log("got test", env.DATASET, env.TOKEN)
return new Response("xxx")
}
if (request.headers.get("content-encoding") === "gzip") {
// This is a logpush batch
console.log("got logs")
// Verify token
if (request.headers.get("Authorization")?.split("earer ")[1] !== env.TOKEN) {
return new Response("invalid token", {
status: 401
})
}
return fetch(`https://cloud.axiom.co/api/v1/datasets/${env.DATASET}/ingest`, {
method: "POST",
headers: {
"Authorization": `Bearer ${env.TOKEN}`,
"content-encoding": "gzip",
"content-type": "application/json"
},
body: request.body
})
}
return new Response("ok")
},
}