ruxo’s gists

ruxo / TidalApi.fs

Created November 26, 2024 10:30

	// #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 / Program.fs

Last active November 14, 2024 10:09

This sample project shows how to use .NET Selenium WebDriver to create a Facebook for submitting a post. It is an adaptation from the Python bot https://github.com/darideveloper/facebook-groups-post-bot/tree/master, but with updated algorithm for pos

	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 / ActorExtension.cs

Last active August 24, 2024 02:57

	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 / run-helpers.fsx

Last active June 1, 2024 23:48

A helper library to assist running multiple command lines and combine their output into the current console. See `sample.fsx` about how to use it. To run the sample, use the command line `dotnet fsi sample.fsx`

	[<AutoOpen>]
	module RunHelpers

	#r "nuget: FSharp.Control.Reactive"

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

ruxo / Program.cs

Last active April 8, 2024 13:23

Show how to use LanguageExt's Eff(ect) with memo to cache value.Note that `LanguageExt.Core` library is needed for running.

	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 / pinger.fsx

Last active February 24, 2024 12:15

Simple example of Akka.Net remoting. To run the example, start Ponger first. ``` dotnet fsi ponger.fsx ``` Then start Pinger in another terminal. ``` dotnet fsi pinger.fsx ```

	#r "nuget:Akka.Remote"

	open System
	open Akka.Actor
	open Akka.Configuration

	type Pinger() =
	inherit UntypedActor()

	let Context = ActorBase.Context

ruxo / ConcurrentMailBox.cs

Last active September 2, 2023 23:10

Simple mailbox processor (Single-thread apartment)

	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 / Serializer.cs

Last active August 29, 2023 00:13

LanguageExt's Seq<T> serializer for Mongo DB

	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 / kafka-consumer.fsx

Last active July 1, 2023 22:45

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

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

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

ruxo / Program.fs

Last active May 2, 2023 23:10

Demonstrate ad-hoc polymorphism in F#. It uses inline function with Statically Resolved Type Parameters feature. Try it in [repl.it](https://replit.com/@ruxozheng/F-Ad-hoc-polymorphism)

	// From: https://angrydexterous.github.io/typeclassish.html

	type Num<'A> =
	abstract member Add: 'A -> 'A -> 'A
	abstract member Subtract: 'A -> 'A -> 'A

	[<Struct; NoComparison; NoEquality>]
	type TInt =
	interface Num<int> with
	member my.Add x y = x + y

Ruxo ruxo