MOD-10709 Pin nightly Rust toolchain and update CI (#418)

* Pin nightly Rust toolchain and update CI

- Add rust-toolchain.toml pinning to nightly-2025-07-30
- Update CI to test both stable and pinned nightly versions
- CI dynamically reads nightly version from toolchain file

* Fix build errors

Author: ephraimfeldblum

.github/workflows/ci.yml

@@ -3,9 +3,23 @@ name: CI
 on: [pull_request]
 
 jobs:
+  get-nightly-version:
+    runs-on: ubuntu-latest
+    outputs:
+      nightly-version: ${{ steps.get-nightly.outputs.version }}
+    steps:
+      - name: Checkout sources
+        uses: actions/checkout@v4
+      - name: Get nightly version from rust-toolchain.toml
+        id: get-nightly
+        run: |
+          NIGHTLY_VERSION=$(grep 'channel = ' rust-toolchain.toml | sed 's/.*"\(.*\)".*/\1/')
+          echo "version=$NIGHTLY_VERSION" >> $GITHUB_OUTPUT
+
   test:
     name: Build and run the unit tests using the latest rust.
     runs-on: ${{ matrix.os }}
+    needs: get-nightly-version
     strategy:
       fail-fast: false
       matrix:
@@ -18,8 +32,8 @@ jobs:
           - [7-0, "7.2"]
           - [7-2, "7.2"]
         toolchain:
-          - 1.81.0
           - stable
+          - ${{ needs.get-nightly-version.outputs.nightly-version }}
 
     steps:
       - name: Checkout sources

rust-toolchain.toml

@@ -0,0 +1,3 @@
+[toolchain]
+channel = "nightly-2025-07-30"
+components = ["rustfmt", "clippy"]

src/context/mod.rs

@@ -1352,7 +1352,7 @@ impl<'a> InfoContextBuilder<'a> {
     }
 
     /// Returns a section builder.
-    pub fn add_section(self, name: &'a str) -> InfoContextBuilderSectionBuilder {
+    pub fn add_section(self, name: &'a str) -> InfoContextBuilderSectionBuilder<'a> {
         InfoContextBuilderSectionBuilder {
             info_builder: self,
             name: name.to_owned(),

src/key.rs

@@ -169,7 +169,7 @@ impl RedisKey {
         Ok(val)
     }
 
-    pub fn get_stream_iterator(&self, reverse: bool) -> Result<StreamIterator, RedisError> {
+    pub fn get_stream_iterator(&self, reverse: bool) -> Result<StreamIterator<'_>, RedisError> {
         StreamIterator::new(self, None, None, false, reverse)
     }
 
@@ -179,7 +179,7 @@ impl RedisKey {
         to: Option<raw::RedisModuleStreamID>,
         exclusive: bool,
         reverse: bool,
-    ) -> Result<StreamIterator, RedisError> {
+    ) -> Result<StreamIterator<'_>, RedisError> {
         StreamIterator::new(self, from, to, exclusive, reverse)
     }
 }
@@ -245,7 +245,7 @@ impl RedisKeyWritable {
         self.key_type() == KeyType::Empty
     }
 
-    pub fn as_string_dma(&self) -> Result<StringDMA, RedisError> {
+    pub fn as_string_dma(&self) -> Result<StringDMA<'_>, RedisError> {
         StringDMA::new(self)
     }
 

src/raw.rs

@@ -268,7 +268,7 @@ pub fn call_reply_big_number(reply: *mut RedisModuleCallReply) -> Option<String>
 /// # Panics
 ///
 /// Panics if the Redis server doesn't support replying with bool (since RESP3).
-#[allow(clippy::not_unsafe_ptr_arg_deref)]
+#[allow(clippy::not_unsafe_ptr_arg_deref, invalid_null_arguments)]
 pub fn call_reply_verbatim_string(reply: *mut RedisModuleCallReply) -> Option<(String, Vec<u8>)> {
     unsafe {
         let mut len: size_t = 0;

src/stream.rs

@@ -19,12 +19,12 @@ pub struct StreamIterator<'key> {
 
 impl<'key> StreamIterator<'key> {
     pub(crate) fn new(
-        key: &RedisKey,
+        key: &'key RedisKey,
         mut from: Option<raw::RedisModuleStreamID>,
         mut to: Option<raw::RedisModuleStreamID>,
         exclusive: bool,
         reverse: bool,
-    ) -> Result<StreamIterator, RedisError> {
+    ) -> Result<StreamIterator<'key>, RedisError> {
         let mut flags = if exclusive {
             raw::REDISMODULE_STREAM_ITERATOR_EXCLUSIVE as i32
         } else {