@ -23,7 +23,7 @@ import NotificationsHandler from './Components/NotificationsHandler.svelte';
import { fireNotification , getEmbedsFromCache , getSelectedFile } from "./utils" ; import { fireNotification , getEmbedsFromCache , getSelectedFile } from "./utils" ;
import { getQueryProcessor , QueryProcessor } from "./websites" ; import { getQueryProcessor , QueryProcessor } from "./websites" ;
import { ifetch , Platform , sendCmd , lqueue , supportedAltDomain , supportedMainDomain } from "./platform" ; import { ifetch , Platform , sendCmd , lqueue , supportedAltDomain , supportedMainDomain , genPort } from "./platform" ;
import TextEmbeddingsSvelte from "./Components/TextEmbeddings.svelte" ; import TextEmbeddingsSvelte from "./Components/TextEmbeddings.svelte" ;
import { HydrusClient } from "./hydrus" ; import { HydrusClient } from "./hydrus" ;
import { registerPlugin } from 'linkifyjs' ; import { registerPlugin } from 'linkifyjs' ;
@ -47,6 +47,7 @@ const processors: ImageProcessor[] =
let cappState : Parameters < typeof appState [ ' set ' ] > [ 0 ] ; let cappState : Parameters < typeof appState [ ' set ' ] > [ 0 ] ;
settings . subscribe ( async b = > { settings . subscribe ( async b = > {
if ( ! b ) return ; if ( ! b ) return ;
csettings = b ;
if ( b . hyd ) { if ( b . hyd ) {
// transition from disable to enabled
// transition from disable to enabled
if ( b . ak ) { if ( b . ak ) {
@ -64,7 +65,6 @@ settings.subscribe(async b => {
} }
} }
} }
csettings = b ;
//processors = [...(!csettings.te ? [thirdeye] : []),
//processors = [...(!csettings.te ? [thirdeye] : []),
// pngv3, pomf, jpg, webm, gif
// pngv3, pomf, jpg, webm, gif
//];
//];
@ -212,69 +212,18 @@ const shouldUseCache = () => {
let cp : CommandProcessor ; let cp : CommandProcessor ;
class CommandProcessor { class BackgroundEmulator {
processor = ProcessWorker ( ) ; async bgCorsFetch ( c : MessagePort ,
pendingFetches : Map < MessagePort , { [ id in number ] : { fetchFully : boolean } } > ,
genid = 0 ; id : number ,
input : string ,
pendinggens : Record < number , AsyncGenerator > = { } ; init? : RequestInit ) {
cmdid = 0 ;
pendingprom : Record < number , ( v ? : any ) = > void > = { } ;
constructor ( ) {
this . processor . onmessage = async ( msg ) = > {
let gen : AsyncGenerator ;
let res : IteratorResult < any , any > ;
switch ( msg . data . type ) {
case 'ipc' :
{
const id = msg . data . msg . id ;
if ( execution_mode != "userscript" ) {
if ( msg . data . msg . name == 'corsFetch' ) {
sendCmd ( msg . data . msg , msg . data . tr ) ;
lqueue [ id ] = ( res : any ) = > {
this . processor . postMessage ( {
type : 'ipc' ,
id ,
res
} ) ;
} ;
} else {
// for complitude, but technically the webworker doesn't run anything besides corsFetch
const repl : any = await sendCmd ( msg . data . msg , msg . data . tr ) ;
repl . id = id ;
this . processor . postMessage ( {
type : 'ipc' ,
id ,
res : repl
} ) ;
}
} else {
if ( msg . data . msg . name == 'fullyRead' ) {
// ignore
this . processor . postMessage ( {
type : 'ipc' ,
res : {
id ,
ok : 1
}
} ) ;
}
if ( msg . data . msg . name == 'corsFetch' ) {
const { args } = msg . data . msg ;
try { try {
const res = await ifetch ( args [ 0 ] , args [ 1 ] ) ; const res = await ifetch ( input , init ) ;
// don't report progress because monkeys don't have a way to expose partial responses anyway
// don't report progress because monkeys don't have a way to expose partial responses anyway
const headersStr = ( res as any ) . responseHeaders ; const headersStr = ( res as any ) . responseHeaders ;
const headerObj = headerStringToObject ( headersStr ) ; const headerObj = headerStringToObject ( headersStr ) ;
c . postMessage ( {
this . processor . postMessage ( {
type : 'ipc' ,
id ,
res : {
id , id ,
ok : res.ok || true , ok : res.ok || true ,
setRes : true , setRes : true ,
@ -286,36 +235,24 @@ class CommandProcessor {
status : res.status , status : res.status ,
bodyUsed : res.bodyUsed , bodyUsed : res.bodyUsed ,
statusText : res.statusText , statusText : res.statusText ,
}
} ) ; } ) ;
if ( ! args [ 1 ] . method || [ 'GET' , 'POST' ] . includes ( args [ 1 ] . method ) ) { if ( [ 'GET' , 'POST' ] . includes ( init ? . method || 'GET' ) ) {
const data = await res . arrayBuffer ( ) ; const data = await res . arrayBuffer ( ) ;
this . processor . postMessage ( { c . postMessage ( {
type : 'ipc' ,
id ,
res : {
id , id ,
pushData : { pushData : {
data data
} }
}
} , [ data ] ) ; } , [ data ] ) ;
} }
// let's hope these are delivered in order :%)
// let's hope these are delivered in order :%)
this . processor . postMessage ( { c . postMessage ( {
type : 'ipc' ,
id ,
res : {
id , id ,
pushData : { pushData : {
} }
}
} , [ ] ) ; } , [ ] ) ;
} catch ( e ) { } catch ( e ) {
this . processor . postMessage ( { c . postMessage ( {
type : 'ipc' ,
id ,
res : {
id , id ,
ok : false , ok : false ,
setRes : true , setRes : true ,
@ -325,14 +262,71 @@ class CommandProcessor {
status : 400 , status : 400 ,
bodyUsed : false , bodyUsed : false ,
statusText : 'shit broke' , statusText : 'shit broke' ,
} ) ;
}
}
constructor ( private port : MessagePort ) {
const pendingFetches = new Map < MessagePort , { [ id in number ] : { fetchFully : boolean } } > ( ) ;
port . onmessage = async ( obj : MessageEvent ) = > {
const { id , name , args , sid , fid , url } = obj . data as any ;
if ( name == "keepAlive" ) {
console . log ( 'im alive, tho?' ) ;
return ;
}
if ( name == "abortCorsFetch" ) {
//chrome.runtime.sendMessage({ name, sid });
return ;
}
if ( name == "corsFetch" ) {
// this handles the reply
( this . bgCorsFetch as any ) ( port , pendingFetches , id , . . . args ) ;
return ;
} }
if ( name == "revoke" ) {
URL . revokeObjectURL ( url ! ) ;
port . postMessage ( {
id , ok : 1
} ) ; } ) ;
return ;
} }
if ( name == "fullyRead" ) {
const obj = pendingFetches . get ( port ) ! ;
if ( obj && fid ! in obj )
obj [ fid ! ] . fetchFully = true ;
port . postMessage ( {
id , ok : 1
} ) ;
return ;
} }
// ignore other commands
const res = await ( Platform as any ) [ name ] ( . . . args ) ;
port . postMessage ( {
id , res
} ) ;
} ;
} }
} break ; }
class CommandProcessor {
processor = ProcessWorker ( ) ;
genid = 0 ;
pendinggens : Record < number , AsyncGenerator > = { } ;
cmdid = 0 ;
pendingprom : Record < number , ( v ? : any ) = > void > = { } ;
constructor ( ) {
this . processor . onmessage = async ( msg ) = > {
let gen : AsyncGenerator ;
let res : IteratorResult < any , any > ;
switch ( msg . data . type ) {
case 'reply' : case 'reply' :
if ( msg . data . id in this . pendingprom ) { if ( msg . data . id in this . pendingprom ) {
this . pendingprom [ msg . data . id ] ( msg . data . res ) ; this . pendingprom [ msg . data . id ] ( msg . data . res ) ;
@ -352,7 +346,20 @@ class CommandProcessor {
} ) ; } ) ;
break ; break ;
} }
} ; } ;
if ( execution_mode != "userscript" ) {
const ipcport = genPort ( ) ;
this . processor . postMessage ( { type : 'ipc' , port : ipcport } , [ ipcport ] ) ;
} else {
const nmc = new MessageChannel ( ) ;
const port1 = nmc . port1 ;
const port2 = nmc . port2 ;
new BackgroundEmulator ( port2 ) ;
const ipcport = port1 ;
this . processor . postMessage ( { type : 'ipc' , port : ipcport } , [ ipcport ] ) ;
}
} }
serializeArg ( m : any ) { serializeArg ( m : any ) {
coomdev
2 years ago