Uses 911K of libraries. Click here for Pure Java version (19870L/119K).
!7 concept StandardScript { S scriptID; } cmodule Cruddie > DynPrintLogAndEnabled { !include #1027628 // HTTP+HTTPS servers transient S salt; transient WebChatBot chatBot; transient CRUD<StandardScript> standardScriptsCRUD; transient CRUD<Conversation> conversationsCRUD; switchable int vadUpdateInterval = 50; switchable double listenTime = 10.0; // listen for 10 seconds after voice activity switchable double transcriptTitleShowTime = 5.0; // how long to show recognized text in window title S myLink() { ret "https://cruddie.site/"; } S botLink() { ret "bot"; /*ret appendWithSlash(myLink(), "bot");*/ } switchable S frontendModuleLibID = "#1027675/ChatBotFrontend"; switchable S backendModuleLibID = "#1027591/DynamicClassesMultiCRUD"; transient S cmdsSnippetID = #1027616; start { standardScriptsCRUD = new CRUD(StandardScript); conversationsCRUD = new CRUD(Conversation); thread enter { pcall { File saltFile = secretProgramFile("salt.txt"); S salt = trimLoadTextFile(saltFile); if (empty(salt)) { saveTextFile(saltFile, salt = randomID()); print("Made salt"); } dm_restartOnFieldChange enabled(); if (!enabled) ret; chatBot = new WebChatBot; chatBot.preprocess = s -> { S s2 = googleDecensor(s); print("Preprocessing: " + s + " => " + s2); ret s2; }; chatBot.templateID = #1027690; chatBot.baseLink = botLink(); chatBot.thoughtBot = new ThoughtBot; chatBot.jsOnMsgHTML = "window.processNewStuff(src);"; chatBot.onBotShown = [[ { var input = $("#status_message")[0]; console.log("input: " + input); if (input) new Awesomplete(input, { minChars: 1, list: [ "I call you Fido", "What is your name?", 'add script "#1027704/SomeCruddieScripts/RepeatAfterMe"', 'add script "#1027704/SomeCruddieScripts/GoPublic"', 'clear scripts' ] }); } ]]; chatBot.afterHeading = "` + ('webkitSpeechRecognition' in window ? ` " + tag("button", "...", onclick := lineBreaksToSpaces([[ startOrStop(); if (bigOn) { lastHadVoice = Date.now(); startVAD(); startUpdater(); } else stopVAD(); ]]), type := 'button, class := 'speechOnBtn, disabled := 'disabled, display := 'inline) /*+ hjs([[console.log("Updating"); window.srUpdate();]])*/ + "` : ``) + `" + hdiv(hsnippetimg(#1102908, width := 24, height := 24, title := "Someone is speaking (either me or you)"), style := "display: inline; visibility: hidden; margin-left: 10px", class := "vadStatus") + hdiv(hsnippetimg(#1102909, width := 24, height := 24, title := "Listening"), style := "display: inline; visibility: hidden; margin-left: 10px", class := "listenStatus") + hdiv(small("Note: All conversations are public rn " + targetBlank("https://www.youtube.com/watch?v=StxQerL0D-o", "(why)"))); chatBot.moreStuff = "window.srUpdate();"; chatBot.start(); set redirectHttpToHttps; start_webServers(serverSocketFactory_botCompanyEtc()); }} } O webServe(S uri, SS params) { Pair<Int, Bool> spamCheck = spamBlocker.checkRequest(uri, serveHttp_clientIP()); if (spamCheck.b) { sleepSeconds(60.0); ret print("go away"); } printVars("webServe", +uri); //S cookie = serveHttp_cookieHandling(); if (startsWith(uri, "/.well-known/")) ret loadTextFile(userDir("validation.txt")); // new-style cookie isn't really used yet S newStyleCookie = nu ServeHttp_CookieHandler(verbose := true).handle(); new Matches m; S uri2 = appendSlash(uri); if (startsWith(uri2, "/bot/", m)) ret chatBot.html("/" + m.rest(), params); if (eq(uri, "/awesomplete.css")) ret serveWithContentType(loadSnippet(#2000595), "text/css"); if (eq(uri, "/awesomplete.js")) ret serveText(loadSnippet(#2000594)); if (endsWith(uri, ".map")) ret ""; if (eq(uri, "/frames")) ret serveFrameSet(params); S jsOnSpeech = [[ if (transcript == 'stop listening') stopVAD(); else window.submitAMsg(transcript); lastHeard = transcript; lastHeardWhen = Date.now(); ]]; S sayBotMsgsScript = [[ window.processNewStuff = function(src) { ]] + (eq(params.get('quiet), "1") ? "" : [[ if ($("#speechResults") == null) return; // no speech // we assume that webkit speech synthesis is present // when there is webkit speech recognition if (!bigOn) return; // not enabled console.log("Got speech"); var match = src.match(/\d+/); if (match == null) return; if (src.match(/NEW DIALOG -->/)) return; console.log("Got incremental"); var re = /bot-utterance">(.*?)</g; var match = re.exec(src); var lastUtterance = null; while (match != null) { lastUtterance = match[1]; match = re.exec(src); } // TODO: properly drop HTML tags/HTML-decode if (lastUtterance) say(lastUtterance); ]]) + [[ }; ]]; S speechUI = ""; /*hdiv( "< Talk to me >", id := 'speechResults, style := "margin: 10px");*/ ret hhtml(hmobilefix() + hhead( htitle("CRUDDIE - I manage your anything") + hLoadJQuery2() + hJsMakeCookie() + [[<link rel="stylesheet" href="awesomplete.css" /><script src="awesomplete.js"></script>]] // took out async ) + hbody(hOnBottom( p(hsnippetimage(#1102905)) + p("Chat bot is doing basic stuff. Documentation coming up.") + stats() + hSpeechRecognition(jsOnSpeech, true, "en-US", false, noWebKit := p("Use Chrome if you want speech recognition"), +speechUI) + hjavascript([[ function say(text) { console.log("Saying: " + text); var u = new SpeechSynthesisUtterance(text); u.lang = 'en-US'; u.onstart = function() { console.log("speech start"); srPause = true; srUpdate(); }; u.onend = function() { srPause = false; srUpdate(); }; window.speechSynthesis.speak(u); } ]] + sayBotMsgsScript) + hjs((S) chatBot.html("/", litmap(), returnJS := true)) + hVAD( [[console.log("voice start"); $(".vadStatus").css("visibility", "visible");]], [[console.log("voice stop"); $(".vadStatus").css("visibility", "hidden");]], false) + hjs_setTitleStatus() + hjs(replaceDollarVars([[ var updater; var lastHadVoice = 0; var lastHeard, lastHeardWhen = 0; //audioMeterDebug = true; function startUpdater() { if (updater) return; console.log("Starting updater"); updater = setInterval(vadMagicUpdate, $interval); srPause = true; } function stopUpdater() { if (!updater) return; console.log("Stopping updater"); clearInterval(updater); updater = null; window.resetTitle(); } function vadMagicUpdate() { if (!bigOn) { stopUpdater(); return; } var now = Date.now(); var hasVoice = vadHasVoice(); var clipping = vadHasClipping(); if (hasVoice) lastHadVoice = now; var shouldListen = lastHadVoice >= now-$listenTime; var titleStatus = ""; if (lastHeardWhen >= now-$transcriptTitleShowTime) titleStatus = lastHeard + " |"; else titleStatus = shouldListen ? $listeningSymbol : ""; if (clipping) titleStatus = "! " + titleStatus; window.setTitleStatus(titleStatus); if (srPause != !shouldListen) { console.log(shouldListen ? "Listening" : "Not listening"); srPause = !shouldListen; srUpdate(); } } // debug mic level /*setInterval(function() { if (audioMeter) console.log("Mic level: " + audioMeter.absLevel); }, 1000);*/ ]], interval := vadUpdateInterval, listenTime := toMS(listenTime), transcriptTitleShowTime := toMS(transcriptTitleShowTime), listeningSymbol := jsQuote(/*"[LISTENING]"*/unicode_cloud()))) )/*, onLoad := "startAwesomplete()"*/)); } S cookieToCaseID(S cookie) { ret md5(cookie + salt); } class Request { S cookie, caseID; S frontend, backend; // module IDs *(S *cookie) { caseID = cookieToCaseID(cookie); frontend = dm_makeModuleWithParams_systemQ(frontendModuleLibID, +caseID); backend = dm_makeModuleWithParams_systemQ(backendModuleLibID, +caseID); dm_call(frontend, 'connectToBackend, backend); dm_call(frontend, 'importCmdsFromSnippetIfEmpty, cmdsSnippetID); dm_call(frontend, 'addScripts, collect scriptID(list StandardScript())); Conversation conv = uniq Conversation(+cookie); forwardSwappableFunctionToObject(dm_mod(frontend), 'chatLog_userMessagesOnly, func -> LS { map(m -> m.text, filter(conv.allMsgs(), m -> m.fromUser)) }, 'get); printVars(+caseID, +backend); } } class ThoughtBot { new ThreadLocal<Request> request; void setSession(S cookie, SS params) { //session.set(uniq_sync(Session, +cookie)); request.set(new Request(cookie)); } S initialMessage() { //ret "Hello from module " + request->backend; ret (S) dm_call(request->backend, 'answer, "stats"); } S answer(S s) { ret (S) dm_call(request->frontend, 'answer, s); } } S stats() { ret p(joinWithBR( "Server temperature is " + dm_cpuTemperature(), n2(numberOfCruddies(), "cruddie") + ", " + n2(vmBus_countResponses chatBotFrontend()) + " loaded", )); } int numberOfCruddies() { ret countDirsInDir(getProgramDir(beforeSlash(frontendModuleLibID))); } visual jtabs("Main", super, "Standard Scripts", standardScriptsCRUD.visualize(), "Conversations", conversationsCRUD.visualize()); S serveFrameSet(SS params) { ret hhtml(hhead_title("CRUDDIE with frames") + tag frameset( tag frame("", name := "leftmonitor") + tag frame("", src := appendParamsToURL(myLink(), params)) + tag frame("", name := "rightmonitor"), cols := "*,550,*")); } }
Began life as a copy of #1027610
download show line numbers debug dex old transpilations
Travelled to 7 computer(s): bhatertpkbcr, mqqgnosmbjvj, pyentgdyhuwx, pzhvpgtvlbxg, tvejysmllsmz, vouqrxazstgt, xrpafgyirdlv
No comments. add comment
Snippet ID: | #1028679 |
Snippet name: | Cruddie Spike [with VAT magic for Chrome] |
Eternal ID of this version: | #1028679/34 |
Text MD5: | cb8a154981fa170c61f92d47c303fd31 |
Transpilation MD5: | 496e02387fc9fb96cea7efe313751ed7 |
Author: | stefan |
Category: | javax |
Type: | JavaX source code (Dynamic Module) |
Public (visible to everyone): | Yes |
Archived (hidden from active list): | No |
Created/modified: | 2020-07-05 15:14:31 |
Source code size: | 10979 bytes / 303 lines |
Pitched / IR pitched: | No / No |
Views / Downloads: | 284 / 8461 |
Version history: | 33 change(s) |
Referenced in: | -