ruxo

name	vet-search
description	Vet web-search results by source authority, aim, and recency, then answer in confidence tiers.

Vet-Search

Treat every search result as a witness to cross-examine, not a fact to copy. Rank each result on three axes — Authority · Aim · Age — then answer in confidence tiers, each citing the sources that earned it.

Process

ruxo

// #r "nuget: TiraxTech.Uri"

open System
open System.Net
open System.Net.Http
open System.Text.Json
open Microsoft.Extensions.Primitives
open RZ.Foundation.Json
open TiraxTech

ruxo

open System
open PostBot
open FSharp.UMX

let [<Literal>] ChromeFolder = @"C:\Users\user-name\AppData\Local\Google\Chrome\User Data"

Scraper.killChrome()

let driver = Scraper.startBrowser { Scraper.StartBrowserOptions.Default with ChromeFolder = ValueSome ChromeFolder }

ruxo

using System.Collections.Frozen;
using System.Runtime.CompilerServices;
using System.Text.Json;
using System.Text.Json.Nodes;
using Akka.Actor;
using Akka.DependencyInjection;
using Akka.IO;
using Microsoft.Extensions.Logging;
using TCRB.CoreApp;

ruxo

[<AutoOpen>]
module RunHelpers

#r "nuget: FSharp.Control.Reactive"

open System
open System.Diagnostics
open System.IO
open System.Threading
open FSharp.Control.Reactive

ruxo

using System;
using LanguageExt;
using static LanguageExt.Prelude;

public static class Program {
  public static void Main (string[] args) {
    var program =
      from v1 in Load
      from _1 in eff(() => Console.WriteLine($"1st value = {v1}"))
      from v2 in Load

ruxo

#r "nuget:Akka.Remote"

open System
open Akka.Actor
open Akka.Configuration

type Pinger() =
    inherit UntypedActor()

    let Context = ActorBase.Context

ruxo

using System.Collections.Concurrent;
using Microsoft.Extensions.Logging;

namespace RZ.Foundation;

/// <summary>
/// A mailbox processor that allows some concurrent dispatching.
/// </summary>
/// <param name="logger">Microsoft Logger</param>
/// <param name="concurrentLimit">Maximum number of concurrent threads allowed to process the mailbox</param>

ruxo

using MongoDB.Bson;
using MongoDB.Bson.Serialization;
using MongoDB.Bson.Serialization.Conventions;
using MongoDB.Bson.Serialization.Serializers;
using LanguageExt;

public class SeqSerializationProvider : IBsonSerializationProvider
{
    public IBsonSerializer? GetSerializer(Type type)
    {

ruxo

#nowarn "760"
#r "nuget:Confluent.Kafka"

open System
open System.Diagnostics
open System.Threading
open Confluent.Kafka

[<Literal>]
let Topic = "test-topic"