CopilotForXcode/Tool/Sources/Workspace/FileChangeWatcher/FSEventProvider.swift at main · github/CopilotForXcode · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
import Foundation

public protocol FSEventProvider {
    func createEventStream(
        paths: CFArray,
        latency: CFTimeInterval,
        flags: UInt32,
        callback: @escaping FSEventStreamCallback,
        context: UnsafeMutablePointer<FSEventStreamContext>
    ) -> FSEventStreamRef?

    func startStream(_ stream: FSEventStreamRef)
    func stopStream(_ stream: FSEventStreamRef)
    func invalidateStream(_ stream: FSEventStreamRef)
    func releaseStream(_ stream: FSEventStreamRef)
    func setDispatchQueue(_ stream: FSEventStreamRef, queue: DispatchQueue)
}

class FileChangeWatcherFSEventProvider: FSEventProvider {
    init() {}

    func createEventStream(
        paths: CFArray,
        latency: CFTimeInterval,
        flags: UInt32,
        callback: @escaping FSEventStreamCallback,
        context: UnsafeMutablePointer<FSEventStreamContext>
    ) -> FSEventStreamRef? {
        return FSEventStreamCreate(
            kCFAllocatorDefault,
            callback,
            context,
            paths,
            FSEventStreamEventId(kFSEventStreamEventIdSinceNow),
            latency,
            flags
        )
    }

    func startStream(_ stream: FSEventStreamRef) {
        FSEventStreamStart(stream)
    }

    func stopStream(_ stream: FSEventStreamRef) {
        FSEventStreamStop(stream)
    }

    func invalidateStream(_ stream: FSEventStreamRef) {
        FSEventStreamInvalidate(stream)
    }

    func releaseStream(_ stream: FSEventStreamRef) {
        FSEventStreamRelease(stream)
    }

    func setDispatchQueue(_ stream: FSEventStreamRef, queue: DispatchQueue) {
        FSEventStreamSetDispatchQueue(stream, queue)
    }
}