Shim IO#pread when not supported

Typically on Windows.
discourse · Aug 4, 2023 · c037b2b · c037b2b
1 parent 6fbb687
commit c037b2b
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 3 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -8,26 +8,35 @@ on:
 
 jobs:
   build:
-    runs-on: ubuntu-latest
-    name: "Ruby ${{ matrix.ruby }} / Failure allowed: ${{ matrix.experimental }}"
+    runs-on: ${{ matrix.os }}-latest
+    name: "Ruby ${{ matrix.ruby }} / ${{ matrix.os }} / Failure allowed: ${{ matrix.experimental }}"
     continue-on-error: ${{ matrix.experimental }}
     timeout-minutes: 5
 
     strategy:
       fail-fast: false
       matrix:
+        os: ["ubuntu"]
         ruby: ["2.6", "2.7", "3.0", "3.1", "3.2"]
         experimental: [false]
         include:
+          - ruby: "3.2"
+            os: "windows"
+            experimental: false
           - ruby: "ruby-head"
+            os: "ubuntu"
             experimental: true
           - ruby: "truffleruby-head"
+            os: "ubuntu"
             experimental: true
           - ruby: "jruby-head"
+            os: "ubuntu"
             experimental: true
           - ruby: "jruby-9.3.9.0"
+            os: "ubuntu"
             experimental: true
           - ruby: "jruby-9.4.0.0"
+            os: "ubuntu"
             experimental: true
     steps:
       - uses: actions/checkout@v3

diff --git a/lib/mini_mime.rb b/lib/mini_mime.rb
@@ -85,12 +85,35 @@ def fetch(key, &blk)
       end
     end
 
+    if ::File.method_defined?(:pread)
+      PReadFile = ::File
+    else
+      # For Windows support
+      class PReadFile
+        def initialize(filename, mode)
+          @mutex = Mutex.new
+          @file = ::File.new(filename, mode)
+        end
+
+        def readline
+          @file.readline
+        end
+
+        def pread(size, offset)
+          @mutex.synchronize do
+            @file.seek(offset, IO::SEEK_SET)
+            @file.read(size)
+          end
+        end
+      end
+    end
+
     class RandomAccessDb
       MAX_CACHED = 100
 
       def initialize(path, sort_order)
         @path = path
-        @file = File.open(@path)
+        @file = PReadFile.open(@path)
 
         @row_length = @file.readline.length
         @file_length = File.size(@path)