Rlog 展示的顺序不对，用上传的time 重排，要求上传的内容是JSON, 并且有 time 字段，time 可以被 new Date(time) 处理，就会重新覆盖默认的时间
// ==UserScript==
// @name Rlog按time重排
// @namespace aizigao
// @version 1.6
// @description Rlog 展示的顺序不对，用上传的time 重排，要求上传的内容是JSON, 并且有 time 字段，time 可以被 new Date(time) 处理，就会重新覆盖默认的时间
// @author aizigao
// @match https://log-search-docker.zuoyebang.cc/explore*
// @grant none
// @license MIT
// ==/UserScript==
;(function () {
'use strict'
const originalFetch = window.fetch
const log = (...args) => console.log('😜', ...args)
function get(obj, path, defaultValue = undefined) {
const keys = Array.isArray(path) ? path : path.split('.')
let result = obj
for (const key of keys) {
result = result ? result[key] : undefined
if (result === undefined) {
return defaultValue
}
}
return result
}
function set(obj, path, value) {
const keys = Array.isArray(path) ? path : path.split('.')
let current = obj
keys.forEach((key, index) => {
if (index === keys.length - 1) {
current[key] = value
} else {
current[key] = current[key] || {}
current = current[key]
}
})
return obj
}
const TARGET_APP_AUTH = ['zphybrid-log-debug', 'zphybrid-log']
const authKey = (() => {
// const search = window.location.search;
const deCodeQuery = decodeURIComponent(window.location.search)
const m = deCodeQuery.match(/app=\\"(.*?)\\"/)
return m ? m[1] : ''
})()
log('authKey', authKey)
const SafeJsonParse = (str) => {
try {
return JSON.parse(str)
} catch (e) {
return str
}
}
const transformTime = (list) => {
log('transformTime', list)
return list.map((i) => {
const { values, ...others } = i
const newValues = values
.map(([_oldTs, objStr]) => {
const obj = SafeJsonParse(objStr)
const time = new Date(obj.time).getTime()
if (typeof obj === 'string') {
log('错误：数据不是JSON')
}
if (!time || Number.isNaN(time)) {
log('没有time 字段')
}
if (!time || Number.isNaN(time) || typeof obj === 'string') {
return [_oldTs, objStr]
}
if (TARGET_APP_AUTH.includes(authKey)) {
const content = JSON.parse(obj.content)
delete obj.content
const {p: pageKey, q: pageSearchPartical,atcxt,att, ...others} = content
return [
String(time * 1e6),
JSON.stringify({
att,
atcxt,
...others,
...obj,
AT_RLOG_RE_TIMING___: 'Rlog time 重置OK',
pageKey: '/static/pad-InkLearn/' + pageKey + '.html',
pageSearchPartical,
z_RLOG_RE_TIMING___old_time: new Date(_oldTs / 1e6),
}),
]
}
return [
String(time * 1e6),
JSON.stringify({
...obj,
AT_RLOG_RE_TIMING___: 'Rlog time 重置OK',
z_RLOG_RE_TIMING___old_time: new Date(_oldTs / 1e6),
}),
]
})
.sort((a, b) => Number(a[0]) > Number(b[0]))
return {
values: newValues,
...others,
}
})
}
window.fetch = async function (resource, init) {
// Check if the request URL matches the target API endpoint
if (
typeof resource === 'string' &&
resource.includes('/loki/api/v1/query_range')
) {
log('Intercepted fetch request:', resource)
// Call the original fetch
const response = await originalFetch(resource, init)
if(response.status>300){
return response
}
// Clone the response so we can modify it
const clonedResponse = response.clone()
const data = await clonedResponse.json()
if(typeof data === 'string'){
return response
}
// Modify the response data
log('Original response data:', data)
const originList = get(data, ['data', 'result'], [])
// Example modification: add a custom field to the response
data.customField = 'Modified content'
if (originList.length) {
try {
const rstList = transformTime(originList)
log('rstList', rstList)
set(data, ['data', 'result'], rstList)
} catch (e) {
log('修改失败', e)
window.alert('RLog 修改失败')
}
}
// Create a new response with the modified data
const modifiedResponse = new Response(JSON.stringify(data), {
status: response.status,
statusText: response.statusText,
headers: response.headers,
})
log('Modified response data:', data)
return modifiedResponse
}
// If not our target URL, just proceed with the normal fetch
return originalFetch(resource, init)
}
})()